Spring for Apache Kafka 2.2 发布

2024年1月31日 147次阅读 来源: Spring开发者

Spring for Apache Kafka 2.2 已经发布，该版本修复了一些问题。

目前，2.1.x版本与2.0.0 kafka-clients jar兼容（从2.1.9开始），但此版本需要2.0.0（并提供2.0.0内置的broker用于测试）。
这个版本有以下亮点：

  • SeekToCurrentErrorHandler现在可以“跳过”（skip）重复失败的记录
  • 这些“跳过”的记录可以发布到一个死信（dead-letter）主题（或由应用程序代码处理）
  • 标头添加了有关故障的诊断信息
  • 使用事务时，可以使用默认的AfterRollbackProcessor实现相同的功能
  • 现在可以使用侦听器容器工厂来创建任意侦听器容器，而不仅仅是@KafkaListener的容器
  • 这样可以更方便地为任何容器使用Spring Boot的自动配置属性
  • @KafkaListener注解现在可以覆盖容器工厂的concurrency和autoStartup属性
  • 新的ErrorhandlingDeserializer可以捕获反序列化异常，然后将其路由到ErrorHandler
  • 内置Kafka Broker现在可以与JUnit 5测试一起使用

更多信息，请参阅文档中的“新增内容”章节和更改日志。

另外，Spring Integration for Apache Kafka（spring-integration-kafka）3.1.0.RELEASE 也已发布，它基于Spring for Apache Kafka 2.2和Spring Integration 5.1构建。

Project Page | GitHub | Issues | Documentation | Stack Overflow | Gitter

    原文作者：Spring开发者
    原文地址: https://zhuanlan.zhihu.com/p/48068133
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞