在本文中,我们将了解如何使用 Spring Boot 设置 Kafka Streams。Kafka Streams 是建立在 Apache Kafka 之上的客户端库。它以声明式的方式使我们可以处理无限的事件流。
一些流数据的真实生活例子可能是传感器数据、股票市场事件流和系统日志。对于本教程,我们将构建一个简单的单词计数流应用程序。让我们首先了解 Kafka Streams 的概览,然后设置示例及其在 Spring Boot 中的测试。
2. 概览
Kafka Streams 提供了 Kafka 主题和关系数据库表之间的二元性。它使我们能够对一个或多个流事件执行诸如联接、分组、聚合和过滤等操作。
大约 6 分钟