紧随 Spring Framework 6.1 的发布，我很高兴宣布 Spring for Apache Kafka 和 Spring AMQP (Spring for RabbitMQ) 的 3.1 版本现已发布。
有关详细内容，请参阅各项目的 3.1.0、3.1.0-RC1 和 3.1.0-M1 版本发布说明 - Spring for Apache Kafka 和 Spring AMQP。
另请参阅文档中的“新增内容”部分以了解亮点：Spring for Apache Kafka Spring AMQP。
我很高兴宣布 Spring for Apache Kafka 和 Spring for RabbitMQ 的新主要版本（3.0.0）现已发布。
这些项目的 3.0.x 版本有以下常见变更：
它们依赖于 Java 17 或更高版本
它们依赖于 Spring Framework 6.0.x
支持创建 GraalVM 原生应用
支持 Micrometer 可观测性和追踪
现在提供 Bill of Materials POMs，以帮助依赖管理
支持全局单一的 EmbeddedKafkaBroker（跨多个测试类）
对 @RetryableTopic（非阻塞重试）的几项增强
KafkaTemplate 方法现在返回 CompleteableFuture 而非已弃用的 ListenableFuture
我很高兴宣布 Spring for Apache Kafka 2.9.0 候选版本 (2.9.0-RC1) 现已在 Spring Milestone 仓库中发布。
此版本并非由 Spring Boot 依赖管理提供，但只要按照此附录所述覆盖 Kafka 依赖，即可与 Boot 2.7（或 2.6）一起使用，特别是当您使用嵌入式 Kafka Broker 时。
此版本使用 3.2.0 版本的 kafka-clients
非阻塞重试的引导过程现在更加健壮
新的错误处理器模式
默认情况下，发生错误后，DefaultErrorHandler 会对上次拉取的剩余记录执行 seek 操作，并在下次拉取时从 broker 重新获取这些记录。在高错误率和大型 max.poll.records 的情况下，这会给网络带来不必要的压力。因此，错误处理器有一个新的属性 seekAfterError，当设置为 false 时，不再对记录进行 seek 操作，而是将剩余记录保留在内存中，并在下次拉取时暂停消费者（如果错误处理器配置为使用 ContainerPausingBackOffHandler，则暂停多次拉取...）
最近发布的 Spring AMQP 版本（2.4.0、2.3.12、2.2.20）包含针对 CVE-2021-22095 的修复，该漏洞可能导致处理超大消息时发生潜在的 OutOfMemoryError。
Spring Boot 2.6.0 和 2.5.7 版本将分别引入 spring-amqp 的 2.4.0 和 2.3.12 版本。Boot 2.4.x 的用户应将 spring-amqp 和 spring-rabbit 版本覆盖为 2.3.12；Spring Boot 2.3.x 的用户应将版本覆盖为 2.2.20。
我很高兴宣布 Spring AMQP 2.4.0 版本现已发布。
使用 Spring Framework 的 RMI 支持进行远程调用的支持已弃用
有关此版本中所有变更的信息，请参阅新增内容。
我很高兴宣布 Spring for Apache Kafka 2.7.0 版本现已发布。
此版本包含一项重要增强功能，这是一项社区贡献。失败的投递可以转发到一系列主题以进行延迟重新投递。
用示例描述最佳
@RetryableTopic(attempts = "5", backoff = @Backoff(delay = 1000, multiplier = 2.0))
@KafkaListener(id = "sk270", topics = "sk270")
public void listen(String in, @Header(KafkaHeaders.RECEIVED_TOPIC) String topic) {
LOG.info(in + " from " + topic);
throw new RuntimeException("test");
}
@DltHandler
public void…2.5.0.RC1 候选版本现已在 Spring milestone 仓库中发布。
更新：2.5.0.RELEASE 已于 5 月 13 日发布。
亮点
kafka-clients 2.5.0（版本号对齐是巧合）。
使用协作式 rebalancing 时，支持对保留分区的可重试偏移量提交异常进行重新提交。
支持新的“fetch-offset-request”生产者栅栏（当 broker 版本为 2.5 或更高时），需要更少的生产者。
支持静态组成员资格。
与 Micrometer 更多的集成。
可选的投递尝试次数头。
RecoveringBatchErrorHandler 可以提交部分批次，并从批次中的失败记录重新开始重放（需要监听器配合）；这现在是批次监听器的默认行为。
为了支持上周发布的 Apache Kafka 2.4.0 版本，我很高兴宣布 Spring for Apache Kafka 2.4 - 2.4.0.RELEASE - 已在 Maven Central 中发布。
此版本在功能上与 2.3.x 版本基本等同，但针对 2.4.0 版本的 kafka-clients 进行编译，并支持新的增量 rebalancing 协议。
2.4.0 版本的 kafka-clients 与 Spring for Apache Kafka 2.3 不进行二进制兼容，因此如果您希望使用 2.4.0 客户端，必须升级到此版本。有关如何覆盖 jar 版本的信息，请参阅参考手册的附录，特别是如果您正在使用 Spring...
