【问题标题】:kafka console producer sending messages continuouslykafka 控制台生产者连续发送消息
【发布时间】:2021-01-09 16:39:30
【问题描述】:

我在 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 

问题是我不断收到消息。昨天它只显示我正在向控制台生产者输入的消息。

如何停止自动发送消息?

如果我正在打字,我需要发送消息,否则它不应该发送空白消息。

【问题讨论】:

标签: apache-kafka console producer


【解决方案1】:

默认情况下,控制台消费者仅获取主题的最新偏移量(仅新消息)

如果要读取已有数据,必须加--from-beginning

如果你想保留运行之间的偏移量,你需要一个--group

【讨论】:

  • 感谢您花时间解决这个问题并给出了答案。但我正在寻找的是如何停止自动发送消息,即使我没有输入任何消息。如果我正在打字,我需要发送消息,否则它不应该发送空白消息。
  • console-producer 在发送消息时总是阻止用户输入。你可以在源代码中看到。
猜你喜欢
  • 2017-02-28
  • 2020-09-16
  • 1970-01-01
  • 2019-09-24
  • 2016-11-13
  • 2019-10-03
  • 2016-07-19
  • 1970-01-01
  • 2020-08-13
相关资源
最近更新 更多