apache-kafka - 如何使用 key 发送 1 条 Kafka 消息？

Question

我正在使用这个命令:bin/kafka-console-producer.sh --bootstrap-server url --topic Notifications --property "parse.key=true"--property "key.separator=: "

我输入这个命令，然后输入:

1: {"producer": 4, "message": {"created_date": "2020-08-04 15:03:19.063196"}}

然后它立即期待第二行。但我只想发送 1 条消息，所以我再次按下回车，然后得到

org.apache.kafka.common.KafkaException: No key found on line 2: q at kafka.tools.ConsoleProducer$LineMessageReader.readMessage(ConsoleProducer.scala:289) 在 kafka.tools.ConsoleProducer$.main (ConsoleProducer.scala:51) 在 kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)

Answer 1

我认为消息确实已发送。 kafka-console-producer 逐行接受输入。每一行(当您通过按 [Enter] 输入换行符时)都会向主题提交一条消息。之后 kafka-console-producer 继续等待下一个输入，如果您发送更多消息。但是，因为对于下一个输入，您尝试发送一个空字符串，它确实不会解析并产生错误。不过，此错误仅针对第二个条目。通常情况下，第一条消息到那时应该已经发送。

正如@Patrick Kelly 在评论中建议的那样，您可以通过针对相关主题运行消费者并查看其中内容来确认这一假设。例如，在 kafka-console-producer 提示中输入消息的同时运行 kafka-console-consumer。