aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10/src/test
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basiscody koeninger2016-11-141-9/+25
* [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e...wm624@hotmail.com2016-11-101-0/+2
* [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ...cody koeninger2016-10-121-5/+7
* [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite testsAdam Roberts2016-09-161-4/+4
* [TEST][STREAMING] Fix flaky Kafka rate controlling testTathagata Das2016-07-261-5/+4
* [SPARK-13569][STREAMING][KAFKA] pattern based topic subscriptioncody koeninger2016-07-082-3/+86
* [SPARK-12177][STREAMING][KAFKA] limit api surface areacody koeninger2016-07-016-41/+64
* [SPARK-12177][TEST] Removed test to avoid compilation issue in scala 2.10Tathagata Das2016-06-301-4/+4
* [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum...cody koeninger2016-06-297-0/+1253