kafka stream分布式

一如乞人不需要形象 发表于: 2020-12-24   最后更新时间: 2020-12-24  

大佬,小白想问一下,kafka stream做分布式流处理,如何把结果汇总到一起的?

比如topic有10个partition,有十个services instance,做带window的word count.

结果是每个instance都会产出对应partition的 <window,Long>吗?难道还有重新订阅汇总么...

相关资料太少了~~



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: kafka Coordinator 等待消费者加入的time-out参数是哪个?以及time-out策略是什么?
下一条: springboot整合kafka bootstrap-servers设置多个ip

  • kafka默认提供了WordCountDemo的例子,你可以参考如下文章
    https://www.orchome.com/957