maropu commented on a change in pull request #28442:
URL: https://github.com/apache/spark/pull/28442#discussion_r419180458
##
File path:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
##
@@ -131,11 +132,33 @@ class KafkaTestUtils(
maropu commented on a change in pull request #28442:
URL: https://github.com/apache/spark/pull/28442#discussion_r419180108
##
File path:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
##
@@ -131,11 +132,33 @@ class KafkaTestUtils(