使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第三部分 - 数据反序列化和序列化

工程 | Soby Chacko | 2019年12月04日 | ...

第一部分 - 编程模型 第二部分 - 编程模型(续)

承接前两篇博文,在本系列关于使用 Spring Cloud Stream 和 Kafka Streams 编写流处理应用程序的文章中,现在我们将深入探讨这些应用程序如何处理入站反序列化和出站序列化的细节。

Kafka Streams 中的三个主要高级类型 - KStream<K,V>KTable<K,V>GlobalKTable<K,V> - 都处理键(key)和值(value)。

通过 Spring Cloud Stream Kafka Streams 支持,键始终使用本地 Serde 机制进行反序列化和序列化。Serde 是一个容器对象,它提供反序列化器和...

使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第二部分 - 编程模型续篇

工程 | Soby Chacko | 2019 年 12 月 03 日 | ...

在上一篇博客中,我们介绍了使用 Spring Cloud Stream 和 Kafka Streams 编写流应用程序的基本函数式编程模型。在本篇博客中,我们将进一步探讨该编程模型。

让我们来看几个场景。

场景 1:单个输入和输出绑定

如果您的应用程序从单个输入绑定消耗数据并向输出绑定产生数据,您可以使用 Java 的 Function 接口来实现。请注意,此处绑定的含义不一定映射到单个 Kafka 主题,因为主题可能是...

本周 Spring - 2019 年 12 月 3 日

工程 | Josh Long | 2019 年 12 月 03 日 | ...

嗨,Spring 的粉丝们!您敢相信——反正我是不敢相信——我们已经进入 2019 年 12 月了?新年前的最后一个月?这个十年的最后一个月?简直难以置信!我甚至无法想象我们是怎么如此之快就走到这一步的,但能走到这一步真是太好了。我从 2011 年 1 月的第一周开始写《本周 Spring》,所以我们即将迎来《本周 Spring》的 9 周年!

当我写下这篇文章时,我正在加拿大参加多伦多站的活动,这是 2019 年 SpringOne Tour 的最后一站。我非常享受在这次活动中进行了一个两小时的演讲,介绍了响应式 Spring 广阔领域中的各种内容...

使用 Spring Cloud Stream 和 Apache Kafka Streams 进行流处理。第一部分 - 编程模型

工程 | Soby Chacko | 2019 年 12 月 02 日 | ...

这是我们一系列博客文章的第一篇,我们将在此探讨如何使用 Spring Cloud Stream 和 Kafka Streams 编写流处理应用程序。

Spring Cloud Stream Horsham 版本(3.0.0) 引入了多项更改,改变了应用程序利用 Apache Kafka 的方式,方法是使用 Kafka 和 Kafka Streams 的绑定器。此版本带来的主要增强功能之一是通过完全函数式编程范例编写应用程序的一流支持。这篇博客文章介绍了如何使用此函数式编程模型来开发流...

A Bootiful Podcast:Spring Tools 负责人 Martin Lippert

工程 | Josh Long | 2019 年 11 月 29 日 | ...

大家好,Spring 粉丝们!在本期节目中,Josh Long(@starbuxman)与 Spring Tools 负责人 Martin Lippert(@martinlippert)谈论了他 K 在 Pivotal 和 Spring 团队的时光,他在 Spring Tools 方面的工作,以及他在语言服务器方面的工作,这些语言服务器现在是 Spring 用户使用 Microsoft 的 Visual Studio Code、emacs 和 Atom 等工具进行集成的重要基础。

感谢您的收听,并祝您感恩节快乐!

本周 Spring - 2019 年 11 月 26 日

工程 | Josh Long | 2019年11月26日 | ...

大家好,Spring 粉丝们!欢迎收看又一期的本周 Spring!本周,我正在日本东京参加 Pivotal Summit Japan 活动。由于家人突发急事,我遗憾地错过了中国和韩国的活动,所以很高兴能在返回加州与家人庆祝感恩节之前,参加这次巡演的最后一站。

顺便说一句……美国感恩节快到了。感恩节是我们美国人反思我们所感恩之事的时候。我想我代表整个 Spring 团队说,我们非常感激您...

宣布发布 Spring Cloud Stream Horsham (3.0.0.RELEASE)

工程 | Oleg Zhurakousky | 2019年11月25日 | ...

我们很高兴地宣布发布 Spring Cloud Stream Horsham (3.0.0.RELEASE) 版本系列,该系列是 Spring Cloud Hoxton.RELEASE(即将发布)的一部分,并基于 Spring Boot 2.2.x 和 Spring Cloud Function 3.0.0.RELEASE 构建,后者也 刚刚发布

Spring Cloud Stream Horsham.RELEASE 模块可在 Maven Central 仓库中使用。

快速亮点

正如在此公告之前的这些帖子(揭秘与简化函数式与响应式流与 Spring Integration事件路由)中所提到的,本次发布的核心主题是函数!.

历史上,Spring Cloud Stream 暴露了基于注解的配置模型,该模型要求用户了解并提供大量可以轻易推断出的样板信息。您可以在此处阅读更多详细信息...

宣布发布 Spring Cloud Function 3.0.0.RELEASE

工程 | Oleg Zhurakousky | 2019年11月25日 | ...

我们很高兴地宣布发布 Spring Cloud Function 3.0.0.RELEASE,它作为 Spring Cloud Hoxton.RELEASE(即将发布)的一部分提供,并基于 Spring Boot 2.2.x。

Spring Cloud Function 3.0.0.RELEASE 模块可在 Maven Central 存储库中使用。

快速亮点

透明类型转换

此版本引入了重构的 FunctionCatalog 实现,该实现提供了诸如函数组合、对响应式和非响应式函数的支持以及更多功能,并且通过 Spring Messaging 提供的 MessageConverters 实现了透明类型转换...

Spring Cloud Task 2.2.1 GA 现已发布

工程 | Glenn Renfro | 2019年11月25日 | ...

我们很高兴地宣布 Spring Cloud Task 2.2.1.RELEASE 现已在 Github 和 Pivotal 下载仓库中可用。非常感谢所有为本次发布做出贡献的人。

新增功能?

Spring Cloud Task 2.2.1.RELEASE 旨在与 Spring Boot 2.2.x 对齐。此新版本中的更新包括

  • 更新所有依赖项。
  • Micrometer 支持。
  • 更新了文档,改进了格式。
  • 当使用 Spring Batch 分区时,启动的任务应用程序现在会填充 external-execution-id。

让我们更详细地了解这些更新。

获取 Spring 新闻通讯

通过 Spring 新闻通讯保持联系

订阅

领先一步

VMware 提供培训和认证,助您加速进步。

了解更多

获得支持

Tanzu Spring 提供 OpenJDK™、Spring 和 Apache Tomcat® 的支持和二进制文件,只需一份简单的订阅。

了解更多

即将举行的活动

查看 Spring 社区所有即将举行的活动。

查看所有