66.6. メッセージヘッダー

kafka.PARTITION_KEY (producer) 定数: PARTITION_KEY

パーティションを明示的に指定します。

Integer

kafka.PARTITION (consumer) 定数: PARTITION

メッセージが格納されたパーティション。

Integer

kafka.KEY (common) 定数: KEY

必須 Producer : すべての関連メッセージが同じパーティションに入るようにするためのメッセージのキー。コンシューマー: 設定されている場合、メッセージのキー。

Object

kafka.TOPIC (consumer) 定数: TOPIC

メッセージの発信元のトピック。

String

kafka.OVERRIDE_TOPIC (producer) 定数: OVERRIDE_TOPIC

メッセージの送信先のトピック (オーバーライドおよび優先)、およびヘッダーは保持されません。

String

kafka.OFFSET (consumer) 定数: OFFSET

メッセージのオフセット。

Long

kafka.HEADERS (consumer) 定数: HEADERS

レコードのヘッダー。

ヘッダー

kafka.LAST_RECORD_BEFORE_COMMIT (consumer) 定数: LAST_RECORD_BEFORE_COMMIT

コミット前の最後のレコードかどうか (autoCommitEnable エンドポイントパラメーターが false の場合にのみ使用可能)。

Boolean

kafka.LAST_POLL_RECORD (consumer) 定数: LAST_POLL_RECORD

現在のポーリングリクエスト内の最後のレコードを示します (autoCommitEnable エンドポイントパラメーターが false または allowManualCommit が true の場合にのみ使用可能)。

Boolean

kafka.TIMESTAMP (consumer) 定数: TIMESTAMP

メッセージのタイムスタンプ。

Long

kafka.OVERRIDE_TIMESTAMP (producer) 定数: OVERRIDE_TIMESTAMP

ProducerRecord には、関連付けられたタイムスタンプもあります。ユーザーがタイムスタンプを提供した場合、producer は提供されたタイムスタンプをレコードにスタンプし、ヘッダーは保持されません。

Long

kafka.RECORD_META (producer) 定数: KAFKA_RECORD_META

メタデータ (recordMetadata エンドポイントパラメーターが true の場合にのみ設定されます)。

List

CamelKafkaManualCommit (consumer) 定数: MANUAL_COMMIT

Kafka consumer を使用する場合に手動オフセットコミットを強制するために使用できます。

KafkaManualCommit