kafka
kafka copied to clipboard
oleksiyk
Apache Kafka 0.9 client for Node
How can a guarantee be made that all messages that are on the topic have been read by someone consumed? For example: When sending 3 messages to a topic X...
By default in no-kafka there is a tentative configuration that defaults to 3. ``` return producer.send(messages, { retries: { attempts: 2, delay: { min: 100, max: 300 } } });...
Hi, We are facing this error every now and then. While the kafka topic receives messages from other sources the one from node sometimes gets this error and message does...
Hi, there is a problem to consume topic that not exist yet, 'no-kafka' create the topic but stop working. steps to reproduce: 1. delete all Kafka and Zookeeper logs 2....
With the `kafka-console-consumer`, there's a `--from-beginning` option for getting all messages across a topic's partitions. I've tried setting the `startingOffset`: ``` const consumer = new kafka.GroupConsumer({ connectionString: KAFKA_URLS, startingOffset: kafka.EARLIEST_OFFSET...
If you pass wrong group id also it's not throwing any error .That issue is resolved now. If group id not there "GroupAuthorizationFailed" error code we are receiving ,so catching...
If you pass wrong group id , It was not throwing any error .That issue is resolved now
I have this situation trying to connect to Kafka broker. Why is this error generated? Is this closing connection event trigger in the broker side or the producer? Please help...
I may be wrong here, but from what I have managed to google so far, it sounds like we now have apis to create and delete topics. Any plans to...
If for any reason, this case is triggered, it stays in the loop, and just keeps printing this error message to the screen. `2018-11-06T22:34:36.712Z ERROR no-kafka-client Full rejoin attempt failed:...
