[KAFKA] 파티션, 헤더, 인터셉터

파티션 ProducerRecord는 토픽, 키, 밸류의 값을 포함한다. 대부분 키값이 지정된 레코드를 쓴다. 키의 역할은 두 가지 메시지에 함께 저장되는 추가적인 정보이기도 하지만 토픽에 속한 여러 개의 파티션 중 해당 메시지가 저장될 파티션을 결정짓는 기준점 같은 키값을 가진 모든 메시지는 같은 파티션에 저장된다. 키값이 null 기본 파티셔너 사용할 때 키값이 Null인 레코드가 주어지면 토픽의 파티션 중 하나에 랜덤으로 저장 카프카 2.4 프로듀서부터는 접착성 처리를 위해 기본 파티셔너에서 Round Robin 알고리즘 사용 접착성 처리 접착성 처리가 있은 경우 key 값이 null인 메시지들은 일단 key 값이 있는 메시지 뒤에 따라붙은 다음에 라운드 로빈 방식으로 배치됨 key 값있는 메시지 뒤에 따라붙기에 접착성 처리 헤더 레코드에는 헤더를 포함할 수 있다. 헤더는 카프카 레코드의 key/value 값을 건드리지 않고 추가 메타데이터를 심을 때 사용함 메시지의 전달 내역을...

원문링크 : [KAFKA] 파티션, 헤더, 인터셉터