I am using kubernetes microserice in which I have create single Kafka micro service to consume all topic and perform its activities. Code sample below: const { Kafka, logLevel } = require("kaf...

In one of my use-case consist of consuming the data, do some operations and produce it to new topic. I'm using https://www.npmjs.com/package/kafkajs npm library. I would like to commit the offset m...

just starting learning Kafka. Im trying to setup a small kafka cluster including 2 brokers. I was successfull in sending messages to my topic when both brokers are up. I want to test the behavior o...

I want to use kafkajs in my Node.js project. Let me show my code. Producer: const producer = kafka.producer(); await producer.connect(); const items = await getItems(); // getting somehow 5k items ...

The Situation I am using kafkajs to write to some dynamically generated kafka topics. I am finding writing to those topics immediately after registering my producer will regularly cause an error: T...

I am trying to use kafkajs in order to create a kafka consumer. However, I get already an error when connecting to kafka: "[BrokerPool] Failed to connect to seed broker, trying another broker from...