Kafka Stream是一个库包，意味着可以随着代码运行和发布，没有资源管理，没有主从节点等等，那么如何以分布式方式处理来自Kafak的topic数据？当你创建你的流，你指定一个应用id，当新的节点使用指定的应用id注册到Kafka的broker中时，被分配到每个节点topic分区将重新负载平衡，每个节点会接受到任务列表（分区+topology）用来运行。
还有流操作的标准操作如map和filter都适合Kafka Stream，Kafka Stream还支持有状态处理器，窗口设置，joining和聚合操作。
Read full article from Kafka Stream简介 -解道Jdon
No comments:
Post a Comment