spark streaming消费kafka: Java .lang.IllegalStateException: No current assignment for partition 1 原因是: 多个相同的Spark Streaming同时消费同一个topic,导致的offset问题。关掉多余的任务,就ok了。