文档首页 > > 开发指南> 消息集成开发指导> 使用客户端连接MQS>

附录:spring-kafka对接限制

附录:spring-kafka对接限制

分享
更新时间:2021/04/08 GMT+08:00

概述

spring-kafka兼容开源Kafka客户端,其与开源Kafka客户端的版本对应关系可参见Spring官网。spring-kafka兼容的Kafka客户端版本主要为2.x.x版本,而ROMA Connect消息集成的Kafka服务端版本为1.1.0和2.3.0版本。因此在Spring Boot项目工程中使用spring-kafka连接ROMA Connect时,请确保客户端与服务端的Kafka版本一致。

若spring-kafka连接的ROMA Connect实例为Kafka 1.1.0版本时,大部分的功能可以正常使用,仅少数新增功能不支持。经排查验证,以下为不支持的功能,除此以外的其他功能暂未发现问题。如果在使用过程中遇到其他问题,请提工单联系技术支持。

不支持zstd压缩类型

Kafka在2.1.0版本新增了zstd压缩类型,而1.1.0版本的Kafka不支持zstd压缩类型。

  • 配置文件:

    src/main/resources/application.yml

  • 配置项:
    spring:
      kafka:
        producer:
          compression-type: xxx
  • 使用限制:

    “compression-type”的值不能设置为“zstd”。

不支持消费者组静态成员功能

Kafka客户端在2.3版本新增了Consumer参数“group.instance.id”,设置了该ID的消费者被视为一个静态成员。

  • 配置文件:

    src/main/resources/application.yml

  • 配置项:
    spring:
      kafka:
        consumer:
          properties:
            group.instance.id: xxx
  • 使用限制:

    不能添加“group.instance.id”参数配置。

分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!非常感谢您的反馈,我们会继续努力做到更好!
反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区论坛频道来与我们联系探讨

智能客服提问云社区提问