aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-18682][SS] Batch Source for KafkaTyson Condie2017-02-071-1/+20
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-101-4/+28
* [SPARK-18588][TESTS] Fix flaky test: KafkaSourceStressForDontFailOnDataLossSuiteShixiong Zhu2016-12-071-27/+48
* [SPARK-18373][SPARK-18529][SS][KAFKA] Make failOnDataLoss=false work with Spa...Shixiong Zhu2016-11-221-5/+15
* [SPARK-17812][SQL][KAFKA] Assign and specific startingOffsets for structured ...cody koeninger2016-10-211-1/+13
* [SPARK-17346][SQL] Add Kafka source for Structured StreamingShixiong Zhu2016-10-051-0/+339