Kafka consumer module Dynamic kafka consumer module developed with kafkajs Current version of kafkajs used 2.2.3