34.5. 메시지 헤더

KafkaConstants.TOPIC

"kafka.TOPIC"

문자열

메시지가 시작된 항목

KafkaConstants.PARTITION

"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 끝점 매개변수가 false인 경우에만 사용 가능)

KafkaConstants.LAST_POLL_RECORD

"kafka.LAST_POLL_RECORD"

부울

현재 폴링 요청 내의 마지막 레코드를 나타냅니다( autoCommitEnable 끝점 매개변수가 false 또는 allowManualCommit 이 true인 경우에만 사용 가능)

KafkaConstants.MANUAL_COMMIT

"CamelKafkaManualCommit"

KafkaManualCommit

Kafka 소비자를 사용할 때 수동 오프셋 커밋을 강제 적용하는 데 사용할 수 있습니다.

KafkaConstants.KEY

"kafka.KEY"

개체

필요: 모든 관련 메시지가 동일한 파티션에 포함되도록 하려면 메시지의 키입니다.

KafkaConstants.OVERRIDE_TOPIC

"kafka.OVERRIDE_TOPIC"

문자열

메시지를 보내는 주제(override 및 precedence)는 보존되지 않습니다.

KafkaConstants.OVERRIDE_TIMESTAMP

"kafka.OVERRIDE_TIMESTAMP"

long

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

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

정수

파티션 명시적으로 지정

KafkaConstants.KAFKA_RECORDMETA

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

List<RecordMetadata>

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