[KAKFA] Producer 설정

ProducerRecord 카프카에 메시지를 쓰는 작업은 ProducerRecord 객체를 생성해서 사용한다. Record가 저장될 토픽과 밸류 지정은 필수, 키와 파티션 지정은 선택사항 ProducerRecord를 전송하는 API를 호출했을 때 Producer가 가장 먼저 하는 일은 Key와 Value를 네트워크에 전송될 수 있도록 직렬화해서 byte 배열로 변환하는 과정 파티션을 지정하지 않았으면 해당 데이터를 파티셔너로 보냄 파티셔너가 파티션을 결정하는 역할을 함 보통 ProducerRecord 객체의 Key 값 사용해서 결정 프로듀서는 레코드를 같은 토픽 파티션으로 전송될 레코들을 모은 Record Batch에 추가함 별도의 스레드가 Record Batch를 적절한 카프카 브로커에게 전송함 Producer 응답 값 메시지가 성공적으로 저장되면 브로커는 토픽, 파티션, 해당 파티션의 레코드의 오프셋을 담은 RecordMetaData 객체를 리턴한다. 에러가 발생하면 에러 리턴됨...

원문링크 : [KAKFA] Producer 설정