[Kafka] kafka-console-producer

hello.kafka 토픽에 데이터를 넣을수 있는 명령어를 실행해보자

키보드로 문자를 작성하고 엔터키를 누르면 별다른 응답없이 메시지 값이 전송된다.

 

kafka-console-producer.sh 쉡 스크립트를 사용하면 된다.

그리고, 메시지를 보낼때 separator를 선언하면, 메시지키를 구분자로 사용할 수 있다.

메시지 키를 동일하게 쓰면, 같은 파티션으로 들어가게 된다.

즉 동일한 메시지키를 쓰면, 같은 파티션으로 들어가게 된다.

메시지 키가 Null인 경우, 라운드 로빈으로 전송한다. 즉 여러 파티션에 들어가게 된다.

 

실습 해보자

bin/kafka-console-producer.sh --bootstrap-server my-kafka:9092 --topic hello.kafka

 

이렇게 하는 경우 해당 토픽으로 메시지가 전달이 된다.

 

메시지키가 있는 경우에는 아래와 같이 사용한다.

bin/kafka-console-producer.sh --bootstrap-server my-kafka:9092 --topic hello.kafka --property "parse.key=true" --property "key.separator=:"

 

해당 케이스에서는 아래와 같이 보내면 된다.

 

kafka-console-producer는 정말 많이 쓰는 쉘이라서 사용방법을 익히면 좋다.

사실 익힐 것도 없이 쓰면 되지만 ㅋ;