有什么方法可以在 kafka-console-producer 中生成一个带有空值的消息(即标记它以便压缩器用墓碑删除它)?
我试过制作“mykey”和“mykey|”。前者产生错误,后者使值成为空字符串。像这样运行生产者:
$KAFKA_HOME/bin/kafka-console-producer --broker-list localhost:9092 --topic mytopic --property "parse.key=true" --property "key.separator=|"
Run Code Online (Sandbox Code Playgroud)