Fixed

org.apache.spark.sql.kafka010.KafkaSourceStressSuite.stress test with multiple topics and partitions

Took 2 min 30 sec.