headerMode = rawのJSON MessageHeaders

Question

私は、SleuthでトレースするSpring Cloud Stream（SCS）カフカ製作アプリを持っています。私は春・メッセージングを公開しようとしている「GenericMessage」（すなわちMessageHeaders +ペイロード）必要の両方によって消費される： （自動的にMessageHeadersに追加されたトレースを継続すべきである）

• SCSの消費者
• MessageHeadersをスキップしてペイロードを処理するSCS/Javaコンシューマーはいません。それが公表される前に、MessageHeaderで トレースエントリはEmbeddedHeaderUtilsすることにより、メッセージの先頭に付加されていますheaderMode = embeddedHeaders（デフォルト）で

。私の非Javaの消費者EmbeddedHeaderUtilsは、純粋なJSON、生headerMode =付きすなわち

?\n invalid-json-headers { payload }

にシリアライズしないとしてこれを処理することはできません。 MessageHeadersが全く送られていない、唯一のペイロードをシリアライズします。私は実際にはそれが作成されたとしてスルースが追加トレース+スパンのID、すなわち含め、全体GenericMessageを公開したい { payload }

すなわち ：

{"headers": {"id": "x", "trace": "y", "span": "z"}, "payload": { ... }}

は、これを実現する方法はありますSCSコンシューマ向けに1つのトピックにパブリッシュするだけでなく、ペイロードだけで別のトピックにパブリッシュすること以外にも、

Answer 1

ので、アウトバウンドメッセージの​​としてそのメッセージを公開：

return MessageBuilder.withPayload(message).build(); 

あなたのメッセージは​​としてシリアル化され、あなたが適切な逆シリアル化後に必要なヘッダにアクセスしに​​をキャストすることができますこの方法。