[解決済み] Kafkaメッセージにカスタムヘッダを追加する

質問

カフカプロデューサーを使用して、ファイルをバイト配列に変換してメッセージとして送信しています。

また、コンシューマ側でファイル名や他のヘッダに基づいてメッセージを処理できるように、メッセージにいくつかのヘッダ、例えばファイル名、タイムスタンプなどを追加する必要があります。

現在私が行っているのは、オブジェクトを作成し、生のメッセージとヘッダをそれにラップして、メッセージとしてバイト配列でオブジェクトを送信することです。

メッセージの公開中にカスタムヘッダーを追加する方法があれば知りたいのですが。

解決方法を教えてください。

カフカはメッセージの内容に対して不可知論者である <ストライク また、リッチ化するための特別な手段も提供していないため、これは自分で行う必要があります。これらのことを扱う一般的な方法は、jsonやavroなどの構造化フォーマットを使用することで、必要なフィールドを自由に定義し、簡単にメッセージにメタデータを追加してKafkaブローカーに送信できます。

この回答はKafka 0.11の時点で古いものです。他の回答を参照してください。