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 >>> >>
