如何使用Kafka工具集生成值为Null的Kafka Record？

我之前也碰到过一模一样的困扰！用你当前的命令发送myKey#时，控制台生产者会把#后面的空字符串当成消息值，而不是我们想要的Null值。下面给你两个靠谱的解决办法：

方法一：直接输入key（不带分隔符） #

当你启用了parse.key=true和key.separator=#后，只输入key内容并回车，生产者就会自动将这条记录的value设为Null。操作步骤：

1. 运行你的生产者命令：

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

2. 在输入提示符下，直接敲入myKey然后回车，不要加后面的#。

这样生成的Kafka记录就是key=myKey, value=null，完全符合你的需求。

方法二：通过管道命令发送（适合批量或脚本场景） #

如果需要在脚本里批量生成Null值记录，可以用echo配合管道，利用换行作为分隔符来实现：

echo "myKey" | bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test.topic --property parse.key=true --property key.separator=$'\n'

这里把key.separator设为换行符，echo输出的myKey作为key，没有后续内容，所以value会被设为Null。

为什么之前的方式不行？ #

你之前输入myKey#时，#作为分隔符，后面的空字符串会被StringSerializer序列化为空字节数组，Kafka会把它当成“空值消息”，而非真正的Null值。只有当生产者识别到没有提供value内容时，才会生成value为Null的记录。

内容的提问来源于stack exchange，提问作者Stole