Show some code Rahul. On Mon, Jan 21, 2019 at 11: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 > > >>> > > >> > > >
