토픽 데이터 테스트용도로 사용
bin/kafka-console-producers.sh --bootstrap-server 로컬카프카브로커 --topic 토픽이름
이렇게 하면 > 이게 화면에 나온다.
자기가 원하는 글 적으면 된다.
설정이 없으면 key-value로 설정된다.
key를 보내기 위해서는 key.separator 설정
bin/kafka-console-producer.sh --bootstrap-server my-kafka:9092 --topic hello.kafka --property "parse.key=true" --property "key.separator=:"
구분자는 자기 마음
이렇게 하면 아까와 마찬가지로 > 이게 화면에 나옴
>k1:1
>k2:2
>k3:3
이런 형식으로 넣기
동일한 메시지 key는 동일한 레코드에 저장된다. -> 동일한 메시지 key가 있는 레코드 들에서 순서를 지킬수 있다.
컨슈머 입장에서는 1:1로 통신하기 때문에 0번부터 가져간다. -> 순서를 지켜서 데이터를 처리하고 싶으면 key를 넣어서 데이터 전송하면 된다!!
smilegate