kafka 发送消息 Exception thrown when sending a message with key=null
这个异常通常发生在 Kafka 发送消息时没有指定消息的 Key 值,而发送消息的方法需要传入 Key 值,因此会抛出该异常。
解决方法是在发送消息时指定一个非空的 Key 值。例如:
ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", "my-key", "my-value");
producer.send(record);
其中,第一个参数是 topic 名称,第二个参数是消息的 Key 值,第三个参数是消息的 Value 值。在这个例子中,我们指定了 "my-key" 作为消息的 Key 值,避免了抛出该异常。
原文地址: https://www.cveoy.top/t/topic/hvOe 著作权归作者所有。请勿转载和采集!