阅读背景:

spark streaming消费kafka: Java .lang.IllegalStateException: No current assignment for partition

来源:互联网 

1 原因是:

  多个相同的Spark Streaming同时消费同一个topic,导致的offset问题。关掉多余的任务,就ok了。  多个相同的Spark Streaming同时消费同一个topic,导致的o




你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: