java - 从 2.21.1 更新到 2.21.2 后，Apache camel kafka 组件无法序列化标头

Question

在我将 apache camel 从版本 2.21.1 更新到 2.21.2 后，我收到以下错误：

由于 Magic v1 不支持记录头

我在https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc看到，在 2.22 版中，所有标题都序列化到主题，我不不知道为什么。我在路由器上设置了几个标头，我不知道它序列化到主题，主要是字节。

我需要做什么？应用 headerFilterStrategy？

标签： javaapache-kafkaapache-camelkafka-producer-api

Answer 1

谢谢

我需要做什么？应用 headerFilterStrategy？

不，这不是过滤器问题。

问题是 Kafka 和您使用的客户端之间的版本不匹配。请检查 Kafka 代理的版本，然后查看骆驼 Kafka 组件使用的消费者版本。确保它们兼容。