私は、Spring Cloud Stream Kafka プロセッサ アプリを構築しています。これは、文字列キーと、場合によっては Kafka トピックからの null ペイロードを使用して生データを消費します。String キーと null ペイロード (Kafka では廃棄 (tombstone) と呼ばれます) を別のトピックに生成したいと考えています。メッセージで生のヘッダーを使用するには、 を出力する必要がありますbyte[]が、 にエンコードKafkaNull.INSTANCEするbyte[]と、文字どおりオブジェクト ハッシュコードの文字列が出力されます。
以外のものを送信しようとするとbyte[]、未加工のヘッダーを使用できません。
これを行う正しい方法は何ですか？ペイロードが null の場合でも、ヘッダーはどこにありますか? 展開を設定producer.headerMode=embeddedHeadersしましたが、違いはないようで、ペイロードとしてハッシュコードがまだあります。