189.3. 메시지 헤더

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

Expand

헤더 상수	헤더 값	유형	설명
`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 소비자를 사용할 때 수동 오프셋 커밋을 강제 적용하는 데 사용할 수 있습니다.

맨 위로 이동