采纳
大佬,小白想问一下,kafka stream做分布式流处理,如何把结果汇总到一起的?
比如topic有10个partition,有十个services instance,做带window的word count.
结果是每个instance都会产出对应partition的 <window,Long>吗?难道还有重新订阅汇总么...
<window,Long>
相关资料太少了~~