时间戳

首页 > 解决方案 > 如何使用 kafka 工具集生成具有空值的 Kafka 记录

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

问题描述

我正在使用以下命令：

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

这使我可以开始键入key#value条目。

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

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

我需要创建一个 Null 值。

标签： apache-kafka

解决方案

kafkacat允许您通过-Z选项制作墓碑。

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

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

推荐阅读