【问题标题】:Apache camel kafka component fail to serialize header after update from 2.21.1 to 2.21.2从 2.21.1 更新到 2.21.2 后,Apache camel kafka 组件无法序列化标头
【发布时间】:2018-08-04 07:05:02
【问题描述】:

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

due Magic v1 不支持记录标题

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

我需要做什么?应用 headerFilterStrategy?

【问题讨论】:

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


    【解决方案1】:

    谢谢

    我需要做什么?应用 headerFilterStrategy?

    没有。不是过滤器问题。

    问题是 Kafka 和您使用的客户端之间的版本不匹配。请检查Kafka broker的版本,然后查看camel Kafka组件使用的是哪个版本的consumer。确保它们兼容。

    【讨论】:

    • 但是在文档中说从版本 2.22 开始,Camel 将所有标头放在 Kafka 标头中,我在标头中有一个对象作为 JSON,而 Kafka 仅支持字节,这就是为什么我认为它是Camel过滤策略,文档说我们可以过滤header for not send to Kafka。
    • @RenatoGarcia 你能提供错误的确切堆栈跟踪吗?
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2021-10-25
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2016-03-19
    • 2022-06-17
    • 2022-11-29
    相关资源
    最近更新 更多