将 apache Camel 从版本 2.21.1 更新到 2.21.2 后,我收到以下错误:
由于 Magic v1 不支持记录 header
我看到https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc在 2.22 版本中,所有 header 都序列化到主题,我不知道为什么。 我在路由器上设置了几个 header ,但我不知道它序列化为主题,并且主要序列化为字节。
我需要做什么?应用 headerFilterStrategy?
最佳答案
谢谢
What I need to do? Apply headerFilterStrategy?
没有。这不是过滤器问题。
问题是 Kafka 和您使用的客户端之间的版本不匹配。请检查Kafka Broker的版本,然后查看Camel Kafka组件使用哪个版本的Consumer。确保它们兼容。
关于java - Apache Camel kafka 组件从 2.21.1 更新到 2.21.2 后无法序列化 header ,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51674839/