189.3. 메시지 헤더

189.3.1. 소비자 헤더

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

헤더 상수헤더 값유형설명

KafkaConstants.TOPIC

"kafka.TOPIC"

문자열

메시지가 시작된 위치의 주제

KafkaConstants.PARTITION

"kafka.PARTITION"

정수

메시지가 저장된 파티션

KafkaConstants.OFFSET

"kafka.OFFSET"

long

메시지의 오프셋입니다.The offset of the message

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 소비자를 사용할 때 수동 오프셋 커밋을 강제 적용하는 데 사용할 수 있습니다.