kafka
kafka copied to clipboard
oleksiyk
Apache Kafka 0.9 client for Node
Hi , I have been using no-kafka for 3-months now with kafka version 0.9 . A month ago, I upgraded to kafka 0.10.1.0, but most of our client-side code is...
I'm interested in using the `no-kafka` client with [IBM Message Hub](https://console.ng.bluemix.net/catalog/services/message-hub/). To achieve this there are some requirements to be met regarding connection and authentication as documented here: [How to...
return producer.init().then(function(){ return producer.send({ topic: '111111', message: { value: 'Hello!' } }); }) .then(function (result) { console.log(result); });
Hi, this package supports client authentication using a certificate and a key but it's really common on local networks to just have encrypted communication usually using self-signed certificates. Would you...
Not a bug. I had forgot to call `producer.init();` before trying `producer.send(...);`, which fails. An exception is raised but the cause is not obvious. Maybe something like "hey numb-skull, you...
@oleksiyk, I'd appreciate it if you can feed back as to whether or not you think this is a viable problem and something that might be happening, of if I'm...
I am exploring kafka clients for node . The one we are using currently just isnt working for us (after a lot of wrappers and hooks to restart the client...
When a misconfigured connection string is pushed to production, I'd like to know about it as soon as I can. After reaching some configurable time threshold, I'd like this driver...
I have a simple producer and trying to add 100000 json records continuously (streaming data) to a topic but after some point of time, the producer is crashed. How to...
I have a simple consumer and I am trying to read from offsets 3 to 5 which do not exist. I want to catch the OffsetOutofRange error and need to...