来自kafka的spark流如何指定轮询事件的截止时间

import org.apache.kafka.clients.consumer.ConsumerConfig
import org.apache.spark.streaming.kafka010.ConsumerStrategies
import org.apache.spark.streaming.kafka010.KafkaUtils

val sparkConf = new SparkConf().setAppName("KafkaSparkStreaming")
val ssc = new StreamingContext(sparkConf, Seconds(5))

val kafkaParams = Map[String, Object](
  ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG -> "kafka-broker1:9092,kafka-broker2:9092",
  ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG -> classOf[StringDeserializer],
  ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG -> classOf[StringDeserializer],
  ConsumerConfig.GROUP_ID_CONFIG -> "group-id",
  ConsumerConfig.AUTO_OFFSET_RESET_CONFIG -> "latest",
  ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG -> "60000" // 设置轮询事件的截止时间为60秒
)

val topics = Array("topic1", "topic2")
val stream = KafkaUtils.createDirectStream[String, String](
  ssc,
  PreferConsistent,
  ConsumerStrategies.Assign[String, String](topics, kafkaParams)
)