java - Apache Camel kafka 组件从 2.21.1 更新到 2.21.2 后无法序列化 header

标签 java apache-kafka apache-camel kafka-producer-api

将 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/

相关文章:

java - 无法从 GET 请求中获取 JSON

java - 如何将 JSON 字符串转换为对象的数组列表

java - 如何使用 Apache Kafka 在 Spring Boot 中使用和保存自定义类型列表?

apache-camel - 基于http响应码的Camel执行处理

java - Camel 和 MQTT 路由

java - 与 T 不兼容的类型

java - kafka.server.KafkaServerStartable - java.lang.OutOfMemoryError : Java heap space

node.js - 卡夫卡-超时错误: Request timed out after 30000ms

java - Apache Camel 的 REST 端点

java - 当我创建方法时,我的 Java 代码显示编译器错误