kafka에서 여러개의 partition을 가지는 msg 전송

우선 3개의 파티션을 가지는 토픽을 생성한다.

 

 

kafka-console-consumer --bootstrap-server localhost:9092 --topic test-topic2 --from-beginning --property print.partition=true

위와 같이 --property print.partition=true를 주면 파티션을 출력하는 것이 가능하다.

 

---

이번에는 key와 value를 나누어서 보내보자

아까와는 다르게 --property key.separator=: --propety parse.key=true를 줌

 

이렇게 키와 벨류와 파티션이 출력됨