在将Apache骆驼从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版中,所有标头都已序列化为该主题,我不知道为什么。
我在路由器上设置了somes标头,但我不知道它序列化为主题,并且主要是字节。

我需要做什么?是否应用headerFilterStrategy?

最佳答案

谢谢


  我需要做什么?是否应用headerFilterStrategy?


否。这不是过滤器问题。

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

关于java - 从2.21.1更新到2.21.2后,Apache camel kafka组件无法序列化 header ,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/51674839/

10-09 06:19
查看更多