I have an edge in Kafkajs consumer, where at times I get a rebalancing error: The group is rebalancing, so a rejoin is needed [Connection] Response Heartbeat(ke
I'm proofing out an integration test with NestJS/KafkaJS. I have everything implemented except the function on the event listener (consumer) for the topic I'm e
I have used KafkaJS library and configured an consumer code to fetch messages from a topic of one of my streaming API. I have created a consumer.js file and I'm