此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.3.5！spring-doc.cadn.net.cn

新增功能

自 3.3 以来 4.0 中的新增功能

本节介绍从版本 3.3 到版本 4.0 所做的更改。有关早期版本中的更改，请参阅更改历史记录。spring-doc.cadn.net.cn

Apache Kafka 4.0 客户端升级

Spring for Apache Kafka 已升级为使用 Apache Kafka 客户端版本4.0.0. 此次升级带来了几个重要的变化：spring-doc.cadn.net.cn

随着 Kafka 4.0 完全过渡到 KRaft 模式，所有基于 ZooKeeper 的功能都已被删除spring-doc.cadn.net.cn
ZooKeeper 依赖项已从项目中删除spring-doc.cadn.net.cn
嵌入式 Kafka 测试框架现在只使用 KRaft 模式spring-doc.cadn.net.cn
这EmbeddedKafkaZKBroker类已被删除，所有功能现在都由EmbeddedKafkaKraftBrokerspring-doc.cadn.net.cn

嵌入式 Kafka 测试框架更改

测试基础设施已显著更新：spring-doc.cadn.net.cn

这EmbeddedKafkaRule已删除 JUnit 4 规则spring-doc.cadn.net.cn
这@EmbeddedKafka注释已通过删除 ZooKeeper 相关属性进行了简化：spring-doc.cadn.net.cn
这kraft属性已被删除，因为 KRaft 模式现在是唯一的选项spring-doc.cadn.net.cn
特定于 ZooKeeper 的属性，如zookeeperPort,zkConnectionTimeout和zkSessionTimeout已被删除spring-doc.cadn.net.cn
KafkaClusterTestKit 导入现在为 KRaft 模式使用新包spring-doc.cadn.net.cn
一些测试已更新，以解决 KRaft 模式下静态端口分配的限制spring-doc.cadn.net.cn
对测试中的复制因子进行了调整，以适应 KRaft 要求spring-doc.cadn.net.cn

ConsumerRecords 构造函数更改

这ConsumerRecords构造函数现在需要一个额外的Map参数，该参数已在整个框架中得到解决。直接使用此构造函数的应用程序将需要更新其代码。spring-doc.cadn.net.cn

创建者接口更新

来自 Kafka Producer 接口的新方法已实现：spring-doc.cadn.net.cn

registerMetricForSubscriptionspring-doc.cadn.net.cn
unregisterMetricFromSubscriptionspring-doc.cadn.net.cn

已删除的已弃用功能

已删除几个已弃用的项目：spring-doc.cadn.net.cn

已弃用的partitioner已从运行时提示中删除类spring-doc.cadn.net.cn
已弃用的sendOffsetsToTransaction方法String consumerGroupId已被删除spring-doc.cadn.net.cn

Kafka Streams API 更改

KafkaStreamBrancher已更新为使用新的split()和branch()方法而不是已弃用的branch()方法spring-doc.cadn.net.cn
这DeserializationExceptionHandler已更新为使用新的ErrorHandlerContextspring-doc.cadn.net.cn

与 Apache Kafka 4.0.0 相关的内部 API 更新

这BrokerAddress类现在使用org.apache.kafka.server.network.BrokerEndPoint而不是已弃用的kafka.cluster.BrokerEndPointspring-doc.cadn.net.cn
这GlobalEmbeddedKafkaTestExecutionListener已更新为仅适用于 KRaft 模式spring-doc.cadn.net.cn

新的消费者再平衡协议

Spring for Apache Kafka 4.0 支持 Kafka 4.0 的新消费者再平衡协议 - KIP-848。有关详细信息，请参阅 New Consumer Rebalace Protocol 文档。spring-doc.cadn.net.cn

支持多值标头

这DefaultKafkaHeaderMapper和SimpleKafkaHeaderMapper支持 Kafka 记录的多值 Header 映射。有关更多详细信息，请参阅支持多值标头映射。spring-doc.cadn.net.cn