Hi Hans, Let me correct this. I am using kafka-node client not node-kafka.
On Tue, Jan 22, 2019 at 3:56 AM Hans Jespersen <h...@confluent.io> wrote: > Do you mean this node-kafka from 4 years ago ( > https://github.com/sutoiku/node-kafka)? > > If so that’s a very very old client, only supports Apache Kafka 0.8 and > stores offsets in zookeeper (which Kafka 0.9 and above no longer do). > > I recommend you use a more up to date nodejs kafka client than this one. > > -hans > > > On Jan 21, 2019, at 10:02 AM, Rahul Singh < > rahul.si...@smartsensesolutions.com> wrote: > > > > I am using node-kafka, I have used consumer.commit to commit offsets but > > don't know why when I restart the consumer it consume the committed > offsets. > > > > Thanks > > > >> On Mon, Jan 21, 2019, 10:24 PM Hans Jespersen <h...@confluent.io wrote: > >> > >> Are you using kafka-node or node-rdkafka? In either case you should call > >> Consumer.commit(cb) or something similar to manually commit offsets (aka > >> acknowledge messages). > >> > >> Alternatively so can set a config parameter on the consumer to > autoCommit. > >> > >> https://github.com/SOHU-Co/kafka-node/blob/master/README.md#consumer > >> > >> https://github.com/Blizzard/node-rdkafka/blob/master/README.md > >> > >> -hans > >> > >>> On Jan 21, 2019, at 5:17 AM, Rahul Singh < > >> rahul.si...@smartsensesolutions.com> wrote: > >>> > >>> I am using in Node with node-kafka module. > >>> > >>>> On Mon, Jan 21, 2019 at 6:45 PM M. Manna <manme...@gmail.com> wrote: > >>>> > >>>> Please read KafkaConsumer javadoc - your answer is already there. > >>>> > >>>> Thanks, > >>>> > >>>> On Mon, 21 Jan 2019 at 13:13, Rahul Singh < > >>>> rahul.si...@smartsensesolutions.com> wrote: > >>>> > >>>>> Hi All, > >>>>> > >>>>> I am testing kafka locally, I am able to produce and consume message. > >>>> But, > >>>>> after consuming the message from topic I want to acknowledge. > >>>>> > >>>>> Looking for solution. Please revert if anyone have. > >>>>> > >>>>> Thanks & Regards > >>>>> Rahul Singh > >>>>> > >>>> > >> >
