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

Question

我正在使用以下命令:

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 的空消息，但不为空。

我需要创建一个 Null 值。

Answer 1

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

通过提供一个 -Z 解释为 NULL 的空消息值，为键“abc”生成一个逻辑删除(压缩主题的“删除”):

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