sparkstreaming local[4]消费Kafka四分区topic,只有一个消费者在工作

新手上路,请多包涵

sparkstreaming消费Kafka,用local[4]模式处理有四个分区的topic,为什么只起来一个消费者,手动维护的四个分区offset更新值都一样,有碰到过这种情况吗?[图片] [图片] [图片] [图片]

阅读 884
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进