spark streaming 消费 kafka 数据时报 Java .lang.IllegalStateException: No current assignment for partition

消费 kafka 数据时刚开始可以稳定跑一会，但是过不了几分钟就跑出此异常程序中断，java.lang.IllegalStateException: No current assignment for partition

我认为可能有问题的代码是 subscribe()，看网上有说用 Assign(),但是那样需要指定 partition，下面是我现在的代码：

val lineDStream: InputDStream[ConsumerRecord[Object, Object]] = KafkaUtils.createDirectStream(
ssc,
LocationStrategies.PreferConsistent,
ConsumerStrategies.Subscribe(kafkaTopics, kafkaParams)
)

如果有哪位知道解决方法，请指教，非常感谢！