我想从服务器获取主题中从头开始的所有消息。
Ex:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testTopic --from-beginning
当使用上面的控制台命令时,我希望能够从一开始就获取主题中的所有消息,但我无法使用 java 代码从一开始就消耗主题中的所有消息。
您可以使用以下命令获取所有消息:
cd Users/kv/kafka/bin
./kafka-console-consumer.sh --bootstrap-server localhost:9092 \
--topic topicName --from-beginning --max-messages 100
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)