org.apache.spark.sql.kafka010.KafkaDataConsumerSuite

(It is not a test it is a sbt.testing.SuiteSelector)

new KafkaDataConsumer instance in case of Task retry

new KafkaDataConsumer instance in case of token renewal

same KafkaDataConsumer instance in case of same token

SPARK-19886: Report error cause correctly in reportDataLoss

SPARK-23623: concurrent use of KafkaDataConsumer

SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair

SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair and same offset (edge-case) - data in use

SPARK-25151 Handles multiple tasks in executor fetching same (topic, partition) pair and same offset (edge-case) - data not in use