Kafka Producer CLI

• Kafka Producer CLI인 kafka-console-produce 는 입력된 데이터를 읽어 kafka에 전송합니다.

Kafka Topic에 메시지 전송하기

CLI 사용법

카프카 토픽 생성

kafka-topics.sh --bootstrap-server localhost:9092 --topic first_topic --create --partitions 3 --replication-factor 1

Kafka v2.5+

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic first_topic

Kafka v2.4이하

kafka-console-producer.sh --broker-list localhost:9092 --topic first_topic

ouput

1 >

위 표시가 보이면 메시지를 전송할 수 있습니다.

주의할 점

1. 메시지는 기본 키인 null 과 함께 전송됩니다.
2. topic이 존재하지 않으면 kafka에서 자동으로 생성될 수 있습니다.
   아직 존재하지 않는 topic을 지정하면 제공된 이름의 새 topic이 기본 partition 수와 replication factor로 생성됩니다.
3. 위 내용은 브로커 설정에 의해 제어되며 아래 파일에서 확인할 수 있습니다. config/server.properties

Key와 함께 메시지 전달하기

• 기본적으로 Kafka topic에 전송된 메시지는 null 키가 포함된 메시지로 생성됩니다.
• parse.key, key.separator와 함께 메시지를 보내야 합니다.

kafka-console-producer.sh --bootstrap-server localhost:9092 --topic first_topic --property parse.key=true --property key.separator=:

ex

>example key:example value
>name:Stephane