samza

Apache Samza提供了一种用于处理来自发布订阅系统（例如Apache Kafka）的流数据的系统。 开发人员编写一个流处理任务，并将其作为Samza作业执行。 然后，Samza在流处理任务和该消息所针对的发布-订阅系统之间路由消息。https://mirrors.tuna.tsinghua.edu.cn/apache/samza/1.2.0/