aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-17841][STREAMING][KAFKA] drain commitQueuecody koeninger2016-10-181-3/+3
* [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ...cody koeninger2016-10-123-7/+32
* [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite testsAdam Roberts2016-09-161-4/+4
* [SPARK-17023][BUILD] Upgrade to Kafka 0.10.0.1 releaseLuciano Resende2016-08-131-1/+1
* [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu...Holden Karau2016-08-081-2/+0
* [SPARK-16776][STREAMING] Replace deprecated API in KafkaTestUtils for 0.10.0.hyukjinkwon2016-08-011-8/+12
* [TEST][STREAMING] Fix flaky Kafka rate controlling testTathagata Das2016-07-261-5/+4
* [SPARK-16535][BUILD] In pom.xml, remove groupId which is redundant definition...Xin Ren2016-07-191-1/+0
* [SPARK-16477] Bump master version to 2.1.0-SNAPSHOTReynold Xin2016-07-111-1/+1
* [SPARK-13569][STREAMING][KAFKA] pattern based topic subscriptioncody koeninger2016-07-083-9/+258
* [SPARK-12177][STREAMING][KAFKA] limit api surface areacody koeninger2016-07-0113-193/+222
* [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-2919-0/+3175