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

Question

我正在使用以下命令：

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

这允许我开始输入key#value条目。

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

如果我尝试发送 [myKey#] 并按 Enter，则在提要上我将看到该密钥的空消息，但不为空。

我需要创建一个 Null 值。

Answer 1

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

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

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

Answer 2

控制台生成器无法生成空记录。它将输入解析为 UTF8 字符串

就我个人而言，我会编写一个简单的 python 或 ruby​​ 脚本来执行此操作