apache-kafka - 使用 kafka 流计算增量值
问题描述
我有一些带有时间戳的指标写入 Kafka 主题。我需要计算指标的当前值和前一个值之间的增量值。我想通过 Kafka 流 API 或 KSQL 来做到这一点，以比我现有的解决方案更好地扩展。
我现在拥有的是 Python 中的一个简单的 Kafka 生产者/消费者，它每次读取一个指标，并使用存储在 Redis 数据库中的先前值计算增量。
非常感谢通过 Kafka 流 API 完成此操作的一些示例代码。
我有一些带有时间戳的指标写入 Kafka 主题。我需要计算指标的当前值和前一个值之间的增量值。我想通过 Kafka 流 API 或 KSQL 来做到这一点，以比我现有的解决方案更好地扩展。
我现在拥有的是 Python 中的一个简单的 Kafka 生产者/消费者，它每次读取一个指标，并使用存储在 Redis 数据库中的先前值计算增量。
非常感谢通过 Kafka 流 API 完成此操作的一些示例代码。
标签： apache-kafkaapache-kafka-streams