如何使用 kafka 工具集生成具有空值的 Kafka 记录答案

【问题标题】：How can I produce a Kafka Record with null value using the kafka tool set如何使用 kafka 工具集生成具有空值的 Kafka 记录
【发布时间】：2020-02-03 18:28:36
【问题描述】：

我正在使用以下命令：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.topic --property parse.key=true --property key.separator=#

这让我可以开始输入 key#value 条目。

但是，无论我尝试什么，我都无法创建 null 条目。

如果我尝试发送 [myKey#] 并按 Enter，我将在提要上看到 Key 的 Empty 消息，但不是 null。

我需要创建一个 Null 值。

【问题讨论】：

这能回答你的问题吗？ Producing a Kafka message with a Null Value (Tombstone) from the Console

标签： apache-kafka

【解决方案1】：

kafkacat 允许您通过-Z 选项生成墓碑。

通过提供一个 -Z 解释为 NULL 的空消息值，为键“abc”生成一个墓碑（压缩主题的“删除”）：

$ echo "abc:" | kafkacat -b mybroker -t mytopic -Z -K:

【讨论】：

【解决方案2】：

控制台生产者不能产生空记录。它将输入解析为 UTF8 字符串

就个人而言，我会编写一个简单的 python 或 ruby 脚本来做到这一点

【讨论】：

设法编写了一个小型 Java 应用程序来实现这一点。感谢您的建议。
kafkacat 也可能有效。现在不记得了