我正在使用Edgware版本中的Spring Cloud Stream绑定器来发送Kafka消息。我也在用Spring Sleuth和Zipkin。
Spring 使用自定义类EmbeddedHeaderUtils将标头嵌入到 Kafka 消息中。这给消息的一些非 Spring 使用者带来了问题，他们将不得不处理这种自定义解码。
我的问题：有没有办法为消息头(例如纯 JSON(配置带有自定义编码器/解码器的 Spring？或者可能使用卡夫卡标头？
理想情况下，任何自定义实现都需要与Spring Sleuth和Zipkin一起使用。
我一直在查看最新的 Finchley 版本，看看是否支持 Kafka 标头，但不确定。
嵌入式标头不可插入，但您可以使用 ...producer.header-mode=raw 禁用它们。
Ditmars (1.3.x(，您可以使用 kafka11 工件，它支持本机标头 - 如果您使用 KafkaEmbedded 代理进行测试，则必须覆盖一堆依赖项(kafka-client、SK、SIK 和 kafka 本身(。见蜥蜴蜴(。
在Gitter上有一个关于覆盖版本的讨论。
spring-kafka 1.3.x 原生使用 0.11，但 1.3.1 及更高版本(当前为 1.3.2(也支持 1.0.0 客户端。
Elmhurst (2.0( - 目前处于里程碑阶段 - 使用SK 2.1.0，它原生使用1.0.0 kafka。