aboutsummaryrefslogtreecommitdiff
path: root/external/kafka-0-10/src/main
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-20156][CORE][SQL][STREAMING][MLLIB] Java String toLowerCase "Turkish l...Sean Owen2017-04-101-3/+6
* [SPARK-19550][BUILD][CORE][WIP] Remove Java 7 supportSean Owen2017-02-161-6/+1
* [SPARK-19227][SPARK-19251] remove unused imports and outdated commentsuncleGen2017-01-182-2/+1
* [SPARK-19206][DOC][DSTREAM] Fix outdated parameter descriptions in kafka010uncleGen2017-01-153-25/+16
* [SPARK-18922][SQL][CORE][STREAMING][TESTS] Fix all identified tests failed du...hyukjinkwon2017-01-101-4/+28
* [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