代码之家 › 专栏 › 技术社区 › Phil Dobson

headerMode=raw的JSON消息头

spring-cloud-sleuth spring-kafka spring-cloud-stream

2

Phil Dobson · 技术社区 · 9 年前

headerMode=embeddedHeaders(默认值): 消息头中的跟踪条目在消息发布之前由EmbeddedHeaderUsers预先添加到消息中。我的非java用户无法处理这个问题,因为EmbeddedHeaderUtils没有序列化为纯JSON,即。

?\n invalid-json-headers { payload }

根本不发送消息头,只序列化有效负载。即 { payload }

我真的只想在创建时发布整个GenericMessage,包括Sleuth添加的跟踪+跨度ID,即:

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

1 回复 | 直到 9 年前

1

Artem Bilan 9 年前

因此,将该消息发布为 payload

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

这样,您的消息将被序列化为 有效载荷 在正确的反序列化和转换之后,您可以访问所需的标头 有效载荷 Message .

推荐文章

user25089203 · 替代Kafka 3.6.2中的@EnableBinding和@StreamListener

2 年前

springenthusiast · 如何将springboot中的重复配置作为jar并用作依赖项

2 年前

bohunn · Kafka Streams-无法搜索状态存储

2 年前

Andrey P. · 添加spring-cloud-starter-bus-Kafka依赖项后,Kafka消费者没有收到消息

3 年前

StevenPG · Spring Cloud Streams错误处理不起作用

3 年前

pankaj · Kafka中的电流偏移量怎么会这么高,而日志端偏移量太低,导致负Kafka滞后过高?

3 年前