时间戳

首页 > 解决方案 > 对kafka中的每个传入数据记录执行计算

apache-kafka - 对kafka中的每个传入数据记录执行计算

问题描述

我正在使用一个 kafka 主题，并且我想在收到新数据记录时执行计算。应该对传入记录的数据和前两个记录的数据进行计算（如此处保存为链接的图片所示）。是否有可能以某种方式缓冲最后两条记录，以便我可以使用这些记录和新记录进行操作？

例子

标签： apache-kafkakafka-consumer-apiapache-kafka-streams

解决方案

您也可以简单地通过使用 KSql 来实现这一点。KSQL 是 Apache Kafka 的 SQL 流引擎。它提供了一个易于使用的交互式 SQL 接口，用于在 Kafka 上进行流处理，而无需使用 Java 或 Python 等编程语言编写代码。请找到教程https://docs.confluent.io/current/ksqldb/tutorials/index.html

推荐阅读