kafkajs: Is there a way to create dynamic number of consumer in consumer group?...

Is it OK to create topics that already exist in KafkaJS?...

How to send message into custom partition in Kafka with Nest Js...

Kafka consumer subscribers -- member assignments being lost (nodejs)...

Why the service of grpc is undefined when i set configuration for kafka?...

KafkaJS producer is disconnected only for transactions...

Kafka There is no leader for this topic-partition as we are in the middle of a leadership election...

How to wait for Kafka respone in a Jest test with KafkaJS?...

NestJS: Global exception filter not catching anything thrown from a Kafka-based microservice app...

Connecting two NestJS gRPC microservices on localhost...

NestJS-Kafka group id unchanged after I updated it in the code...

Kafkajs - multiple consumers reading from same topic and partition...

Detect and control on clientside when a kafkajs consumer or producer timeouts...

NestJs/microservices Kafka - Consume messages per batch...

Is there a way for the consumer the get the n last messages with KafkaJS?...

Can't send Kafka messages though topic and producer both exist...

Question on designing a Kafka Consumer in node.js and making it idempotent...

How to stop receiving kafka-metadata messages on a topic...

Nest.js Inject kafka client to the service...

Waiting for leadership elections in KafkaJS...

Why does Promise.race not resolve in kafkajs eachMessage callback...

Read a kafka topic and expose the data via Rest API for prometheus to scrape ( Nodejs)...

How to have multiple Kafka brokers replication...

Is there any way for a Consumer to send an acknowledgement to a producer implemented using kafka(kaf...

Kafka Producer: Disconnect after sending message vs keeping connection open...

KafkaJS: ECONNREFUSED when trying to produce a message on a topic...

NestJs EventBus duplicates event at EventHandler...

kafkajs - gracefully stop kafkajs instance after disconnect...

Why is my kafkajs client (Node.js/express.js) throwing 'TypeError: topics.forEach is not a funct...

Failed to connect to seed broker with kafkajs...