191.4. 메시지 헤더

191.4.1. 소비자 헤더

Kafka에서 메시지를 사용할 때 다음 헤더를 사용할 수 있습니다.

헤더 상수	헤더 값	유형	설명
`KafkaConstants.TOPIC`	`"kafka.TOPIC"`	`문자열`	메시지가 시작된 주제입니다.
`KafkaConstants. CryostatITION`	`"kafka.PARTITION"`	`정수`	메시지가 저장된 파티션
`KafkaConstants.OFFSET`	`"kafka.OFFSET"`	`long`	메시지의 오프셋입니다.
`KafkaConstants.KEY`	`"kafka.KEY"`	`개체`	구성된 경우 메시지의 키
`KafkaConstants.HEADERS`	`"kafka.HEADERS"`	`org.apache.kafka.common.header.Headers`	레코드 헤더
`KafkaConstants.LAST_RECORD_BEFORE_COMMIT`	`"kafka.LAST_RECORD_BEFORE_COMMIT"`	`부울`	커밋 전 마지막 레코드인지 여부( `autoCommitEnable` endpoint 매개변수가 `false`인 경우에만 사용 가능)
`KafkaConstants.MANUAL_COMMIT`	`"CamelKafkaManualCommit"`	`KafkaManualCommit`	Kafka 소비자를 사용할 때 수동 오프셋 커밋을 강제 적용하는 데 사용할 수 있습니다.

191.4.2. 생산자 헤더

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

헤더 상수	헤더 값	유형	설명
`KafkaConstants.KEY`	`"kafka.KEY"`	`개체`	required 모든 관련 메시지가 동일한 파티션에 있는지 확인하기 위해 메시지의 키
`KafkaConstants.TOPIC`	`"kafka.TOPIC"`	`문자열`	메시지를 보내는 주제( `bridgeEndpoint` 끝점 매개변수가 `true`인 경우에만 읽기)
`KafkaConstants.PARTITION_KEY`	`"kafka.PARTITION_KEY"`	`정수`	파티션을 명시적으로 지정합니다( `KafkaConstants.KEY` 헤더가 정의된 경우에만 사용됨)

Kafka로 메시지를 보낸 후 다음 헤더를 사용할 수 있습니다.

헤더 상수	헤더 값	유형	설명
`KafkaConstants.KAFKA_RECORDMETA`	`"org.apache.kafka.clients.producer.RecordMetadata"`	`List<RecordMetadata>`	메타데이터( `recordMetadata` 끝점 매개변수가 `true`인 경우에만 구성됨)

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

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

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

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

Red Hat 소개

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

© 2024 Red Hat, Inc.