데일리디벨롭

프로듀서는 카프카에서 데이터의 시작점이다. 프로듀서 애플리케이션은 카프카에 필요한 데이터를 선언하고 브로커의 특정 토픽의 파티션에 전송한다. 프로듀서가 데이터를 전송할 때 리더 파티션을 가지고 있는 카프카 브로커와 직접 통신하는데, 카프카 브로커로 데이터를 전송할 때 내부적으로 파티셔너, 배치 생성 단계를 거친다. 프로듀서 내부 구조 ProducerRecord: 프로듀서에서 생성하는 레코드, 오프셋은 미포함 send(): 레코드를 전송 요청하는 메서드 Partitioner: 어느 파티션으로 전송할지 지정하는 파티셔너 Accumulator: 배치로 묶어 전송할 데이터를 모으는 버퍼 Default Partitioner 프로듀서 API를 사용하면 UniformStickyPartitioner 와 RoundRob..