kafka
kafka copied to clipboard
oleksiyk
Apache Kafka 0.9 client for Node
The rationale for this PR: https://nodejs.org/en/docs/guides/buffer-constructor-deprecation/ Among other things, fixes warnings on Node 10.x
Hi, are there plans to add support for message timestamps, implemented in Kafka 0.10 and described in https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message ? It boils down to * adding a timestamp field to Message...
Hello, Could you help with this compilation issue on Angular 6? **+Environment Information** OS [e.g. Mac, Arch, Windows 10]: OSX 10.13.4 Node Version [e.g. 8.2.1]: 10.1.0 NPM Version [e.g. 5.4.2]:...
There are 3 Kafka nodes we are running in production currently. We have applied rolling updates to kafka systems and kafka-broker-3 was made the primary for some topics temporarily (during...
I see that in the below line the error is ignored and we proceed forward for then block. https://github.com/oleksiyk/kafka/blob/2178dea0f3372fabd34b9ae3a277ae2145c74945/lib/group_consumer.js#L89 I get both of these messages one after another. I had...
Hi, Kafka 0.11.0 version have new features like adding headers in Kafka message. Could you please let us know if you are already working on updating this module to add...
@oleksiyk any plans to support the latest kafka release? Maybe you do already :) I can try running the tests with the latest kafka
The call to `Client.fetchRequest` in `BaseConsumer_fetch` wraps requests to all brokers in a `Promise.all()`, meaning that one slow/misbehaving broker can leave us idle in spite of data being returned by...
Is there a quick way to check if a topic exists? I understand not wanting to support auto create, but in my integration test scripts I typically use the auto-create...
Hi , We have been using no-kafka since 6 months in production . We run multiple instances of no-kafka code running as consumer. We have been observing that sometimes the...
