如何解决kafka控制台生产者连续发送消息
我正在Windows中运行Kafka。
我正在使用以下命令创建一个Kafka控制台制作器
C:\kafka_2.11-2.4.0\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic input-topic
并使用以下命令创建kafka控制台使用者
C:\kafka_2.11-2.4.0\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic input-topic
问题是我不断收到消息。昨天，它只显示了我输入给控制台生产者的消息。
如何停止自动发送消息？
如果我要键入消息，则需要发送消息，否则它不应发送空白消息。
解决方法
默认情况下，控制台使用者仅获得该主题的最新偏移量（仅新消息）
如果要读取现有数据，则必须添加--from-beginning
如果要保留运行之间的偏移量，则需要--group
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。