更新时间:2023-08-28 GMT+08:00

附录:spring-kafka对接限制

概述

spring-kafka兼容开源Kafka客户端,其与开源Kafka客户端的版本对应关系可参见Spring官网。spring-kafka兼容的Kafka客户端版本主要为2.x.x版本,而ROMA Connect消息集成的Kafka服务端版本为1.1.0、2.7版本。因此在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”参数配置。