org.apache.spark.streaming.kafka010.KafkaDataConsumerSuite

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

concurrent use of KafkaDataConsumer

KafkaDataConsumer reuse in case of same groupId and TopicPartition

new KafkaDataConsumer instance in case of Task retry