嗨，Spring 粉丝们！欢迎来到另一期《本周 Spring》！今天我刚刚结束了在澳大利亚布里斯班的 YOW！大会的演讲。真的，这是我个人最喜欢的展会之一。和其他演讲者相比，我觉得自己像个冒牌货。我强烈推荐这个展会。

我正准备登机飞回旧金山，我们还有很多事情要做，所以让我们继续吧！

• Spring Cloud Data Flow 2.3.0 GA 版发布
• 使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第 6 部分 - 状态存储和交互式查询
• 使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第 5 部分 - 应用程序自定义
• Spring Data R2DBC 正式发布
• 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 在之前的迭代中支持注册多个版本的任务应用程序，但通过重新加载以前执行中使用的命令行参数、部署属性和应用程序属性来以实用方式运行它们的能力……

第 1 部分 - 编程模型 第 2 部分 - 编程模型续 第 3 部分 - 数据反序列化和序列化 第 4 部分 - 错误处理 第 5 部分 - 应用程序自定义

在本部分（本系列的第六部分也是最后一部分）中，我们将研究 Spring Cloud Stream Binder for 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 个修复、改进和依赖项升级。感谢所有通过问题报告和拉取请求做出贡献的人。

您如何提供帮助？

如果您有兴趣提供帮助，请查看问题存储库中的 "适合贡献" 标签。如果您有任何疑问，请使用 stackoverflow.com 上的 spring-boot 标签 向社区提问，或在 Gitter 上与社区聊天。

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

我荣幸地代表团队和所有贡献者宣布 Spring Boot 2.2.2 现已发布，可从 repo.spring.io 和 Maven Central 获取。

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

您如何提供帮助？

如果您有兴趣提供帮助，请查看问题存储库中的 "适合贡献" 标签。如果您有任何疑问，请使用 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
• 支持事务
• 命名参数支持（方言感知）
• 仓储（Repositories）
• Kotlin 协程扩展

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

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

在这篇博文中，我们将继续讨论 Spring Cloud Stream 对 Kafka Streams 的支持。我们将详细阐述自定义 Kafka Streams 应用程序的方法。

自定义 StreamsBuilderFactoryBean

Kafka Streams 绑定器使用 StreamsBuilderFactoryBean（由 Spring for Apache Kafka 项目提供）来构建 StreamsBuilder 对象，该对象是 Kafka Streams 应用程序的基础。此工厂 Bean 是一个 Spring 生命周期 Bean。出于各种原因，通常必须在启动此工厂 Bean 之前对其进行自定义。如关于错误处理的 上一篇博文 中所述，您需要自定义 StreamsBuilderFactoryBean……

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

在本系列文章中，我们将继续探讨 Kafka Streams 的 Spring Cloud Stream 绑定器，在这篇博文中，我们将研究 Kafka Streams 绑定器中提供的各种错误处理策略。

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

处理反序列化异常

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