26.5.2. 생산자 헤더


Kafka에 메시지를 전송하기 전에 다음 헤더를 구성할 수 있습니다.

Expand
헤더 상수헤더 값유형설명

KafkaConstants.KEY

"kafka.KEY"

개체

required 모든 관련 메시지가 동일한 파티션에 있는지 확인하기 위해 메시지의 키

KafkaConstants.OVERRIDE_TOPIC

"kafka.OVERRIDE_TOPIC"

문자열

메시지를 보내는 주제(override 및 take precedence)와 헤더가 유지되지 않습니다.

KafkaConstants.OVERRIDE_TIMESTAMP

"kafka.OVERRIDE_TIMESTAMP"

long

ProducerRecord는 또한 관련 타임스탬프를 갖습니다. 사용자가 타임스탬프를 제공하면 생산자가 제공된 타임스탬프를 사용하여 레코드를 정렬하고 헤더가 유지되지 않습니다.

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

정수

명시적으로 파티션을 지정

동적 항목에 메시지를 보내려면 생산자에서 제거된 메시지와 함께 전송되지 않는 일회성 헤더로 KafkaConstants.OVERRIDE_TOPIC 을 사용합니다.

메시지가 Kafka로 전송되면 다음 헤더를 사용할 수 있습니다.

Expand
헤더 상수헤더 값유형설명

KafkaConstants.KAFKA_RECORDMETA

"org.apache.kafka.clients.producer.RecordMetadata"

List<RecordMetadata>

metadata ( recordMetadata 끝점 매개변수가 true인 경우에만 구성됨)

맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat