kafka
kafka copied to clipboard
oleksiyk
Apache Kafka 0.9 client for Node
Great package. Is it possible to serialize a producer message using some like https://www.npmjs.com/package/json-serialize ? return producer.send({ topic: 'kafka-test-topic', partition: 0, message: { value: 'Hello!' } });
We use [bunyan](https://github.com/trentm/node-bunyan) for our logging needs but no-kafka only allowed us to send in 1 logFunction. This meant that we couldn't use log levels properly. I've tried to remedy...
Upon receiving a message via Kafka I have to do some processing. When the processing succeeds the offset is committed and if the fails the consumer is ended. When the...
I am trying to subscribe to 2 different topics, but have the handler be different. So basically i am defining a strategy array with 2 objects as following: ``` var...
How `handlerConcurrency` works for consumers? Will it retain partition/key based order?
We are doing a prototyping using no-kafka . Producer code based on standard examples. One producer , reading couple of messages from a file and sending data to a specific...
Why is a partition required when I send keyed messages? I'm a little new to Kafka, but I thought I understood that when using keys, "producer guarantees that all messages...
Consumers are not able to consume from the consumer due to `OffsetOutOfRange` error. I am adding `recoveryOffset` to recover subscription in case of OffsetOutOfRange. ``` let consumer = new kafka.GroupConsumer({...
Hi , I'm using your plugin for loggin kafka data but I had found one missing feature that when all retry attempts gets fired we must fire an event so...
in base_consumer around line 70 the offset for the partition is set to the offset of the last message in the messageSet _even if the dataHandler returned an error_ (because...
