实时处理事件 Streams与Quarkus Kafka (实时处理事件的软件)

到目前为止，对事件的处理都是无状态的，因为事件都是遵循这样的步骤，即接收、处理并发送至 sink 处理器（也就是发送至一个主题或控制台输出），但是，为了统计某部电影播放的次数，我们需要在内存记住电影被播放了多少次，并且当任意用户再次观看超过 10 分钟的时候，要对这个统计数字递增一次。此时，事件的处理就要以有状态的方式进行了。