190.4.2. 생산자 헤더

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

헤더 상수헤더 값유형설명

KafkaConstants.KEY

"kafka.KEY"

개체

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

KafkaConstants.TOPIC

"kafka.TOPIC"

문자열

메시지를 보내는 주제 ( bridgeEndpoint endpoint 매개변수가 true인 경우에만 읽기)

KafkaConstants.PARTITION_KEY

"kafka.PARTITION_KEY"

정수

명시적으로 파티션을 지정합니다 ( KafkaConstants.KEY 헤더가 정의된 경우에만 사용됨)

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

헤더 상수헤더 값유형설명

KafkaConstants.KAFKA_RECORDMETA

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

List<RecordMetadata>

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