Github user daroo commented on a diff in the pull request: https://github.com/apache/spark/pull/19789#discussion_r152951885 --- Diff: external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala --- @@ -211,8 +211,8 @@ private[spark] class KafkaRDD[K, V]( var requestOffset = part.fromOffset def closeIfNeeded(): Unit = { - if (!useConsumerCache && consumer != null) { - consumer.close + if (consumer != null) { + consumer.close() --- End diff -- formatting changed
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org