Spring 粉丝们！欢迎收看另一期《本周 Spring 动态》！今天我刚刚结束在澳大利亚布里斯班的活动，在那里参加了盛大的 YOW! 大会。这绝对是我最喜欢的大会之一。我感觉自己和其他演讲者比起来像个冒牌货。我强烈推荐这次大会。

我马上就要登上回旧金山的航班了，我们还有很多内容要讲，所以我们开始吧！

• Spring Cloud Data Flow 2.3.0 GA 发布
• 使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第六部分 - 状态存储和交互式查询
• 使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第五部分 - 应用程序定制
• Spring Data R2DBC 正式发布 (GA)
• Spring Boot 2.2.2 现已发布
• Spring Boot 2.1.11 现已发布
• 在上周的《A Bootiful Podcast》中，我与 Pivotal 的 Katrina Bakas 聊了 Pivotal HealthWatch 产品、Kubernetes、Cloud Foundry 等内容。
• …

随着 Spring Boot 2.2 的近期发布，我们在此宣布 Spring Boot 2.1 的维护将于 2020 年 11 月 1 日结束。

在此之前，我们将继续发布偶尔的维护版本，但我们建议所有用户尽快考虑升级到 Spring Boot 2.2。从 2.1 升级到 Spring Boot 2.2 应该不会太困难，升级说明可在 WIKI 上找到。

为了帮助跟踪支持版本状态，我们还引入了一个新的“支持版本”WIKI页面。您一眼就能看到哪些 Spring Boot 版本是…

2.3.0 版本为 Spring Boot 2.2.x 和 Spring Cloud Hoxton 带来了大量增强和通用兼容性更改。

任务的持续部署

随着任务应用程序为了跟上业务需求而发展得越来越快，需要一种自动化的方式来通过 Data Flow 消费新版本。虽然 Data Flow 在之前的版本中已经支持注册任务应用程序的多个版本，但通过重新加载先前执行中使用的命令行参数、部署属性和应用程序属性来以实用的方式运行它们的能力一直…

第一部分 - 编程模型 第二部分 - 编程模型（续） 第三部分 - 数据反序列化和序列化 第四部分 - 错误处理 第五部分 - 应用程序定制

在本部分（本系列第六也是最后一部分），我们将探讨 Spring Cloud Stream Kafka Streams 绑定器如何支持 Kafka Streams 中的状态存储和交互式查询。

命名状态存储

当您需要在应用程序中维护状态时，Kafka Streams 可以让您将该状态信息具体化为命名状态存储。Kafka Streams 中有几个操作需要跟踪状态，例如count、aggregate、reduce、各种windowing操作以及其他操作。Kafka Streams 在大多数情况下使用一个名为RocksDB的特殊数据库来维护此状态存储（除非您显式更改…

我很高兴地宣布，代表团队以及所有贡献者，Spring Boot 2.1.11 已发布，现可通过 repo.spring.io 和 Maven Central 获取。

此次发布包含了 53 项修复、改进和依赖项升级。感谢所有通过问题报告和拉取请求做出贡献的人。

你如何提供帮助？

如果您有兴趣提供帮助，请查看 issue 仓库中的 “适合贡献”标签。如果您有一般性问题，请在 stackoverflow.com 上使用 spring-boot 标签提问，或在 Gitter 上与社区交流。

项目页面 | GitHub | 问题 | 文档 | Stack Overflow | …

我代表团队以及所有贡献者，很高兴地宣布 Spring Boot 2.2.2 已发布，现可在 repo.spring.io 和 Maven Central 获取。

此版本包含 88 项修复、改进和依赖升级。感谢所有通过报告问题和提交拉取请求做出贡献的人。

你如何提供帮助？

如果您有兴趣提供帮助，请查看 issue 仓库中的 “适合贡献”标签。如果您有一般性问题，请在 stackoverflow.com 上使用 spring-boot 标签提问，或在 Gitter 上与社区交流。

项目页面 | GitHub | 问题 | 文档 | Stack Overflow | …

我谨代表团队以及所有贡献者，非常高兴地宣布 Spring Data R2DBC 1.0 已正式发布，可从 repo.spring.io 和 Maven Central 获取！

Spring Data R2DBC 1.0 是一个非阻塞式数据库客户端库，用于支持 刚刚发布的 R2DBC 规范，让您能够构建使用 SQL 数据库的响应式应用程序。Spring Data R2DBC 最显著的特性包括：

• 数据访问的功能性响应式声明
• 流畅 API
• 支持事务
• 命名参数支持（方言感知）
• 仓库
• Kotlin Coroutines 扩展

Spring Data R2DBC 1.0 需要 JDK 8 或更高版本以及任何 R2DBC 驱动程序。前往start.spring.io并添加 R2DBC 来配置您的依赖项，或者，如果您已经在使用 Spring Boot R2DBC starter，请将您的spring-boot-bom-r2dbc升级到0.1.0.M3…

第一部分 - 编程模型 第二部分 - 编程模型（续） 第三部分 - 数据反序列化和序列化 第四部分 - 错误处理

在本篇博文中，我们将继续探讨 Spring Cloud Stream 对 Kafka Streams 的支持。我们将详细介绍如何自定义 Kafka Streams 应用程序。

自定义 StreamsBuilderFactoryBean

Kafka Streams binder 使用StreamsBuilderFactoryBean，该工厂由Spring for Apache Kafka项目提供，用于构建StreamsBuilder对象，而该对象是 Kafka Streams 应用程序的基础。这个工厂 Bean 是一个 Spring 生命周期 Bean。通常，在启动之前必须自定义这个工厂 Bean，原因有很多。正如在关于错误处理的上一篇博客文章中所述，您需要自定义StreamsBuilderFactoryBean…

第一部分 - 编程模型 第二部分 - 编程模型（续） 第三部分 - 数据反序列化和序列化

在本篇博文中，我们将继续探讨 Spring Cloud Stream 的 Kafka Streams 绑定器的系列内容，着重讨论 Kafka Streams 绑定器中可用的各种错误处理策略。

Kafka Streams 中的错误处理主要集中在反序列化（入站）和生产（出站）过程中发生的错误。

处理反序列化异常

Kafka Streams 允许您注册反序列化异常处理器。默认行为是，当出现反序列化异常时，它会记录该错误并使应用程序失败 (LogAndFailExceptionHandler)。它还允许您记录并跳过记录，并使应用程序继续运行 (LogAndContinueExceptionHandler)。通常，您提供相应的…