代码之家  ›  专栏  ›  技术社区  ›  Renato Garcia

从2.21.1更新到2.21.2后,Apache camel kafka组件未能序列化头

kafka-producer-api apache-camel apache-kafka java
  •  1
  • Renato Garcia  · 技术社区  · 6 年前

    在我将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?

    1 回复  |  直到 6 年前
        1
  •  1
  •   mrnakumar    6 年前

    谢谢

    我需要做什么?应用headerFilterStrategy?

    不,这不是过滤问题。

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

    推荐文章
    elenwen  ·  在配置中发现未知的功能门KafkaNodePools
    6 月前
    ljuk  ·  连接器启动时的Debezium信号表
    1 年前
    Shubham Snehi  ·  Golang Segmentation在消费者组迁移时获得一半分区
    1 年前
    RushHour  ·  无法定义Kafka配置的卷以便使用docker通过CLI启动生产者
    1 年前
    Hossein Rouhi  ·  优化Docker中的Kafka性能:单个ZooKeeper与多个、Broker计数的影响
    1 年前
    Narut Promsuparoj  ·  Kafka连接器时间戳转换器与SMT一起使用时不工作
    1 年前
    user23351472  ·  从卡夫集群中移除Broker的正确方法
    1 年前
    Varun Sharma  ·  从Kaffa主题消费并添加到列表中
    1 年前
    zloodeyka  ·  Confluent rest prozy基本身份验证不起作用
    1 年前
    Kumar Saras  ·  我可以在Kafka Streams拓扑和普通Kafka消费者之间使用相同的组id吗?
    1 年前
    关于  
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号