메시지 키가 지정된 데이터 전송 프로듀서

ProducerRecord 생성 시 파라미터로 추가해야 한다. 

토픽 이름, 메시지 키, 메시지 값을 순서대로 파라미터로 넣고 생성했을 경우 메시지 키가 지정된다. 

 

ProducerRecord<String, String> record = new ProducerRecord<>
                ("test", "Pangyo", "23");

 

 

확인하기

 

메시지 키가 지정된 데이터는 kafka-console-consumer 명령을 통해 확인할 수 있다. 

property 옵션의 print, key, key.seperator 값을 주면 출력 화면에서

메시지 키, 값을 함께 확인할 수 있다. 

key.seperator설정값을 기준으로 나뉘어 한 줄로 출력된다. 

 

 

 

 

 

파티션을 직접 지정하고 싶을때)

토픽 이름, 파티션 번호, 메시지 키,값을 순서대로 파라미터로 넣고 생성하면 된다.

파티션 번호는 토픽에 존재하는 파티션 번호로 설정해야 한다. 

 

int partitionNo = 0;
ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC_NAME, 
partitionNo, messageKey, messageValue) ;