aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basiscody koeninger2016-11-143-7/+104
* [SPARK-18212][SS][KAFKA] increase executor poll timeoutcody koeninger2016-11-031-1/+2
* [SPARK-17841][STREAMING][KAFKA] drain commitQueuecody koeninger2016-10-181-3/+3
* [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ...cody koeninger2016-10-122-2/+25
* [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
* [SPARK-13569][STREAMING][KAFKA] pattern based topic subscriptioncody koeninger2016-07-081-6/+172
* [SPARK-12177][STREAMING][KAFKA] limit api surface areacody koeninger2016-07-017-152/+158
* [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum...cody koeninger2016-06-2911-0/+1824