27.5.2. プロデューサーヘッダー

Kafka にメッセージを送信する前に、以下のヘッダーを設定できます。

Expand

ヘッダー定数	ヘッダーの値	タイプ	説明
`KafkaConstants.KEY`	`"kafka.KEY"`	`オブジェクト`	必須: 関連するすべてのメッセージが同じパーティションに配置されるようにするためにメッセージのキー
`KafkaConstants.OVERRIDE_TOPIC`	`"kafka.OVERRIDE_TOPIC"`	`文字列`	メッセージを送信するトピック(override およびが優先されます)で、ヘッダーは保持されません。
`KafkaConstants.OVERRIDE_TIMESTAMP`	`"kafka.OVERRIDE_TIMESTAMP"`	`Long`	ProducerRecord には関連するタイムスタンプもあります。ユーザーがタイムスタンプを提供した場合、プロデューサーは指定のタイムスタンプでレコードにタイムスタンプを付け、ヘッダーは保持されません。
`KafkaConstants.PARTITION_KEY`	`"kafka.PARTITION_KEY"`	`整数`	パーティションを明示的に指定します。

メッセージを動的トピックに送信する場合は、プロデューサーで削除されたメッセージと共に送信されない 1 回限りのヘッダーとして使用される 1 回限りのヘッダーとして使用される KafkaConstants.OVERRIDE_TOPIC を使用します。

メッセージが Kafka に送信された後、以下のヘッダーを使用できます。

Expand

ヘッダー定数	ヘッダーの値	タイプ	説明
`KafkaConstants.KAFKA_RECORDMETA`	`"org.apache.kafka.clients.producer.RecordMetadata"`	`List<RecordMetadata>`	メタデータ( `recordMetadata` エンドポイントパラメーターが `true`の場合のみ設定)

トップに戻る