用于在Kafka上构建无状态应用程序的流处理框架