1. 问题描述
我创建了一个名称为myTest的topic，该topic有三个分区,在我的应用中spark streaming以direct方式连接kakfa，但是发现只能消费一个分区的数据，多次更换comsumer group依然如此。的topic，该topic有三个分区,在我的
阅读背景：
解决spark streaming集成kafka时只能读topic的其中一个分区数据的问题
来源：互联网
分享到：
