Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basis | cody koeninger | 2016-11-14 | 3 | -7/+104 |
* | [SPARK-18212][SS][KAFKA] increase executor poll timeout | cody koeninger | 2016-11-03 | 1 | -1/+2 |
* | [SPARK-17841][STREAMING][KAFKA] drain commitQueue | cody koeninger | 2016-10-18 | 1 | -3/+3 |
* | [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ... | cody koeninger | 2016-10-12 | 2 | -2/+25 |
* | [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu... | Holden Karau | 2016-08-08 | 1 | -2/+0 |
* | [SPARK-16776][STREAMING] Replace deprecated API in KafkaTestUtils for 0.10.0. | hyukjinkwon | 2016-08-01 | 1 | -8/+12 |
* | [SPARK-13569][STREAMING][KAFKA] pattern based topic subscription | cody koeninger | 2016-07-08 | 1 | -6/+172 |
* | [SPARK-12177][STREAMING][KAFKA] limit api surface area | cody koeninger | 2016-07-01 | 7 | -152/+158 |
* | [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum... | cody koeninger | 2016-06-29 | 11 | -0/+1824 |