This tool let's you consume messages from a topic.
to use the old consumer implementation, replace
--bootstrap-server
with--zookeeper
.
Display simple messages:
kafka-console-consumer --bootstrap-server localhost:9092 --topic test
Consume old messages:
In order to see older messages, you can use the --from-beginning
option.
Display key-value messages:
kafka-console-consumer --bootstrap-server localhost:9092 --topic test-topic \
--property print.key=true \
--property key.separator=,