紧随 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 可观测性和跟踪
现在提供物料清单 POM 以帮助进行依赖项管理
支持全局单个 EmbeddedKafkaBroker（跨多个测试类）
对 @RetryableTopic（非阻塞重试）进行了一些增强
KafkaTemplate 方法现在返回 CompleteableFuture 而不是 ListenableFuture，后者已弃用
我很高兴地宣布 Spring for Apache Kafka 2.9.0 的候选版本 (2.9.0-RC1) 现已在Spring 里程碑存储库中发布。
Spring Boot 依赖项管理不提供此版本，但只要您按照此附录中所述覆盖 Kafka 依赖项，就可以将其与 Boot 2.7（或 2.6）一起使用，尤其是在使用嵌入式 Kafka 代理时。
此版本使用 3.2.0 kafka-clients 版本
非阻塞重试引导现在更加健壮
新的错误处理程序模式
默认情况下，在发生错误后，DefaultErrorHandler 会对上次轮询中剩余的记录执行查找，并在下次轮询时从代理重新获取它们。在错误率高且 max.poll.records 较大的情况下，这会导致网络上的不必要压力。因此，错误处理程序具有一个新的属性 seekAfterError，当设置为 false 时，它不会查找记录，而是将剩余的记录保留在内存中，并暂停使用者以进行下次轮询（或如果错误处理程序配置为使用 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 现已发布。
对RabbitMQ Stream 插件 的初步支持
使用 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 里程碑存储库中发布。
更新：2.5.0.RELEASE 于 5 月 13 日发布。
亮点
kafka-clients 2.5.0（版本号的对齐是巧合）。
在使用协作重新平衡时，支持为保留的分区重新提交可重试偏移量提交异常。
支持新的“fetch-offset-request”生产者围栏（当代理为 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 编译，并支持新的增量重新平衡协议。
2.4.0 kafka-clients 与 Spring for Apache Kafka 2.3 不兼容，因此如果您希望使用 2.4.0 客户端，则必须升级到此版本。请参阅参考手册中的附录，了解如何覆盖 jar 版本，尤其是在使用 Spring…
