在发送kafka消息时,报以下错误:

 原因:

 <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
    <version>2.2.3.RELEASE</version>
 </dependency>

项目中引入的sleuth链路追踪依赖包,kafka版本太低(版本:0.10.1),两者版本不兼容,导致sleuth在header中添加了X-B3-SpanId来实现微服务跟踪时,抛出“Magic v1 does not support record headers”错误。

修改方案:在yml配置文件中,关闭kafka的sleuth追踪。如下所示:

spring:
  sleuth:
    messaging:
      kafka:
        enabled: false

PS:redis版本过低,也会导致与sleuth版本不兼容,也可以采用关闭redis的sleuth来解决。如下:

spring:
  redis:
    enabled: false

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐