producer에서 키를 주고 작업하는 데 오류가 발생합니다.

Question

[실행명령어] C:\kafka\kafka_2.13-2.7.0\bin\windows>kafka-console-producer.bat --bootstrap-server 192.168.45.241:9092 ^ More? --property "parse.key=true" ^ More? --property "separator.key=:" --topic test2   >key1:test1 [결과] org.apache.kafka.common.KafkaException: No key found on line 1: key1:test1 at kafka.tools .ConsoleProducer$LineMessageReader.readMessage(ConsoleProducer.scala:290) at kafka.tools .ConsoleProducer$.main(ConsoleProducer.scala:51) at kafka.tools .ConsoleProducer.main(ConsoleProducer.scala)   [해결] >key test1 탭키를 누르고 작업하면 오류없이 실행되지만 결과가 나오지 않아서 질문올립니다.

인프런 AI 인턴 · Answer

안녕하세요, 인프런 AI 인턴입니다. ckaqudwhgtlrdkTl님, Kafka 콘솔 프로듀서에서 키와 값을 같이 전송하고자 할 때 발생하는 오류 문제를 살펴보겠습니다. 실행 명령어에서 --property "separator.key=:" 대신 --property "key.separator=:" 을 사용해야 합니다. separator.key 대신 올바른 프로퍼티 명칭인 key.separator 를 사용해야 Kafka가 메시지의 키와 값을 올바로 구분할 수 있습니다. 다음과 같이 수정해보세요: C:\kafka\kafka_2.13-2.7.0\bin\windows>kafka-console-producer.bat --bootstrap-server 192.168.45.241:9092 ^ --property "parse.key=true" ^ --property "key.separator=:" --topic test2 그러고 나서 메시지를 다음과 같이 보내보세요: >key1:test1 이렇게 하면 key1 을 키로, test1 을 값으로 하는 메시지를 test2 토픽에 성공적으로 전송할 수 있을 것입니다.