Spring for Apache Kafka 2.2 发布

Spring for Apache Kafka 2.2 发布了
,虽然 2.1.x 版本与 2.0.0 kafka-clients jar 相兼容(自 2.1.9 起),但此版本要求 2.0.0(并提供 2.0.0 嵌入式代理以进行测试)。

更新亮点:

  • The SeekToCurrentErrorHandler
    can now "skip" records that fail repeatedly

  • Such "skipped" records can be published to a dead-letter topic (or otherwise disposed of by application code)

    • Headers are added with diagnostics about the failure

  • When using transactions, the same functionality can be achieved with the default AfterRollbackProcessor

  • You can now use the listener container factory to create any arbitrary listener container, not just containers for @KafkaListener
    s

    • This allows more convenient use of Spring Boot’s auto configuration properties for any container

  • @KafkaListener
    annotations can now override the container factory’s  concurrency
    and  autoStartup
    properties

  • The new ErrorhandlingDeserializer
    can catch deserialization exceptions which are then routed to the  ErrorHandler

  • The embedded kafka broker can now be used with JUnit 5 tests

有关更多信息,请参阅文档中的 “新增内容”
一章和 更新日志

此外,Spring Integration for Apache Kafka (spring-integration-kafka) 3.1.0.RELEASE 也已发布,它基于 Spring for Apache Kafka 2.2 和 Spring Integration 5.1。

Spring for Apache Kafka (spring-kafka) 项目将核心 Spring 概念应用于基于 Kafka 的消息传递解决方案。它提供了一个“模板”作为发送消息的高级抽象。它还为带有 @KafkaListener 注解和“侦听器容器(listener container)”的消息驱动的 POJO 提供支持。这些库促进了依赖注入和声明的使用。在所有这些情况下,您将看到 Spring Framework 中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。

原文 

https://www.oschina.net/news/101326/spring-for-apache-kafka-2-2-released

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Spring for Apache Kafka 2.2 发布

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址