附录：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”参数配置。