Apache Kafka(3) - 카프카 기본 커맨드 라인2

KIM IL HWAN·2022년 3월 6일
0

apache-kafka

목록 보기
4/4
post-thumbnail

kafa-console-producer.sh

이전 글에서 생성한 토픽에 데이터를 넣을 수 있는 kafka-console.producer.sh 커맨드를 알아보자. 토픽에 넣는 데이너는 레코드(record)라 부르며 메세지 키-값 (key-value) 쌍으로 구성되어 있다.

bin 디렉토리의 kafaka-console-producer.sh 실행 명령과 옵션으로 -bootstrap-server my-kafka:9092 \ 입력 후

--topic 옵션의 값으로 이전에 생성한 토픽이름을 입력하면 된다. 그리고 아무런 문자를 입력 후 엔터를 누르면 별다른 응답 없이 메세지가 전달된다.

맨 상단 토픽의 넣는 데이터는 key-value 쌍으로 구성되어 있다고 설명 했지만 위 내용은 메세지만 전송되는 형태로 키 값은 null로 기본 설정되어 있다.

참고해야할 점은 kafka-console-producser.sh 로 전송되는 값은 ByteArraySerializer로만 직렬화 되기
때문에 String이 아닌 타입으로는 직렬화화여 전송이 불가능 하다.
그렇기 때문에 다른 타입으로 전송을 하고자 한다면 카프카 프로듀서 프로그램을 직접 개발해야 한다.

kafka-console-consumer.sh

kafka-console-producser 명령을 통해 토픽으로 메세지를 전송했다면 잘 도착했는지 확인이 필요한데 kafka-console-consumer 명령으로 도착한 메세지를 확인 가능하다.

--bootstrap-server 옵션에 클러스터 정보, --topic에 확인하고자 하는 토픽명을 입력이 필요하다.

--from-beginning 옵션은 토픽에 저장된 처음 데이터부터 출력한다.

0개의 댓글