JSON MessageHeaders with HeaderMode=原始

Question

我有一个Spring Cloud Stream（SCS）Kafka制作应用程序，配置了Sleuth进行跟踪。我正在尝试发布一个spring消息“GenericMessage”（即MessageHeaders负载），它需要由以下两个用户使用：

• SCS消费者（应继续自动添加到MessageHeaders的跟踪）

headerMode=embeddedHeaders（默认设置）：消息头中的跟踪条目在消息发布之前由EmbeddedHeaderUtils预先添加到消息中。我的非java消费者无法处理这个问题，因为EmbeddedHeaderUtils没有序列化为纯JSON，即。

？\n无效的json-Headers{payload}

headerMode=raw时：根本不发送MessageHeaders，只序列化有效负载。i、 e.<代码>{有效载荷}

我真的只想在创建时发布整个GenericMessage，包括Sleuth添加的跟踪范围ID，即：

{"标头"：{"id"："x"，"trac"："y"，"spans"："z"}，"有效负载"：{...}}

除了为SCS用户发布一个主题和另一个仅使用有效负载的主题之外，还有其他方法可以实现这一点吗？

Answer 1

因此，将该消息发布为出站消息的有效负载：

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

这样，您的消息将被序列化为有效负载，在正确反序列化并将有效负载转换为消息后，您可以访问所需的标头。