小编Thi*_*oth的帖子

因此，我正在评估Kafka。在我们的用例中，必须创建一个包含从一个事件到下一个事件的“经过的时间”的新主题，这主要是因为传感器将向Kafka报告“开”或“关”。因此，具有时间戳，传感器名称和状态，可以创建持续时间为“ on”和“ off”状态的新主题。

1. 这在KSQL中可行吗？
2. 还是应该真的让消费者或流处理器来解决这个问题？

我的数据是这样的：

{ 2019:02:15 00:00:00, sensor1, off}
{ 2019:02:15 00:00:30, sensor1, on} 

得到结果

{ 2019:02:15 00:30:00, sensor1, off, 30sec }. 

本质上，必须组合多个传感器的状态才能确定机器的组合状态。数百甚至不是最终工厂中的数千个传感器