Apache Kafka Consumer - terminate from console

Question

I am new to Apache Kafka and I am trying to consume messages from a topic. I ran the following from the console to see the messages:

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning

But after that I could see a consumer being created called "console-consumer-4158" and I accidentally closed the console.

How to terminate the running consumer?

score 0 · Answer 1 · edited May 23 '17 at 12:25

0

the process itself will be stopped after you terminate consumer.
as you are using old consumer API, groupId (console-consumer-4158) + information about consumed offsets are stored in zookeeper. There is no process that automatically delete not-used groups ( see more)

edited May 23 '17 at 12:25

Community

answered Feb 28 '17 at 22:40

Natalia

That's my question. How the consumer will get terminated or how to terminate from our end? – Pavithra K C Feb 28 '17 at 23:17
console consumer is a simple java process. If you close console, the process will be automatically killed – Natalia Mar 01 '17 at 16:04

1 Answers1