Kafka - console-consumer.sh

topic에 있는 데이터를 임시 조회하기 위해 사용

--from-beginning -> 토픽에 저장된 가장 처음 데이터부터 출력

메시지 키-값 확인 하려면...?

--property print.key=true
--property key.separator="-"

다른 옵션

--max-message n -> 최대 컨슘 메시지 개수(n개)
--partition n -> 특정(n) 파티션(key 포함 데이터가 특정 파티션에만 들어왔는지 확인할 때 사용)

--group -> 컨슈머 그룹
-> 특정 목적을 가진 컨슈머들을 묶음으로 사용하는 것을 뜻한다.

bin/kafka-console-consumer.sh --bootstrap-server my-kafka:9092 --topic 토픽이름 --property print.key=true --property key.separator="-" --from-beginning
-> 가장 처음 데이터부터 키-값 출력

Test

bin/kafka-console-producer.sh --bootstrap-server 클러스터 이름 --topic 토픽 이름
-> 콘솔로 데이터 보내기(넣기)

bin/kafka-console-consummer.sh --bootstrap-server 클러스터 이름 --topic 토픽 이름
-> 데이터 컨슘