[Kafka] Error when sending message to topic {topic-name} with key: null, value: 1 bytes with error

kafka-console-producer로 메시지를 추가하려고 할때 해당 에러가 발생했습니다.

 

$ ./kafka-console-producer.sh --broker-list {ip1}:9092,{ip2}:9092 --topic {topic name}

 

Error when sending message to topic {topic-name} with key: null, value: 1 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.InvalidRecordException: This record has failed the validation on broker and hence will be rejected.

 

 

아래 문서를 보면 key 없이도 테스트가 가능한 것으로 보이나, 해당 에러가 발생한다면 아래와 같이 key 옵션을 추가하여 테스트할 수 있습니다.

 

$ ./kafka-console-producer.sh --broker-list {ip1}:9092,{ip2}:9092 --topic {topic name} --property parse.key=true --property key.separator=

$ 1, halfstorage
$ 2, halftest
$ 3, a
$ 4, b
$ 5, c
$ 6, d
$ 7, e

 

 

 

출처: riptutorial.com/apache-kafka/example/27965/kafka-console-producer

apache-kafka - kafka-console-producer | apache-kafka Tutorial