191.4. メッセージヘッダー

191.4.1. consumer ヘッダー

次のヘッダーは、Kafka からのメッセージを使用するときに使用できます。

ヘッダー定数	ヘッダーの値	タイプ	説明
`KafkaConstants.TOPIC`	`"kafka.TOPIC"`	`String`	メッセージの発信元のトピック
`KafkaConstants.PARTITION`	`"kafka.PARTITION"`	`Integer`	メッセージが格納されたパーティション
`KafkaConstants.OFFSET`	`"kafka.OFFSET"`	`Long`	メッセージのオフセット
`KafkaConstants.KEY`	`"kafka.KEY"`	`Object`	メッセージのキー (設定されている場合)
`KafkaConstants.HEADERS`	`"kafka.HEADERS"`	`org.apache.kafka.common.header.Headers`	レコードのヘッダー
`KafkaConstants.LAST_RECORD_BEFORE_COMMIT`	`"kafka.LAST_RECORD_BEFORE_COMMIT"`	`Boolean`	コミット前の最後のレコードかどうか (`autoCommitEnable` エンドポイントパラメーターが `false` の場合にのみ使用可能)
`KafkaConstants.MANUAL_COMMIT`	`"CamelKafkaManualCommit"`	`KafkaManualCommit`	Kafka consumer を使用する場合に手動オフセットコミットを強制するために使用できます。

191.4.2. producer ヘッダー

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

ヘッダー定数	ヘッダーの値	タイプ	説明
`KafkaConstants.KEY`	`"kafka.KEY"`	`Object`	必須すべての関連メッセージが同じパーティションに入るようにするためのメッセージのキー
`KafkaConstants.TOPIC`	`"kafka.TOPIC"`	`String`	メッセージの送信先のトピック (`bridgeEndpoint` エンドポイントパラメーターが `true` の場合のみ読み取り)
`KafkaConstants.PARTITION_KEY`	`"kafka.PARTITION_KEY"`	`Integer`	明示的にパーティションを指定します (`KafkaConstants.KEY` ヘッダーが定義されている場合にのみ使用されます)

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

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

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

© 2024 Red Hat, Inc.