Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | [SPARK-17510][STREAMING][KAFKA] config max rate on a per-partition basis | cody koeninger | 2016-11-14 | 1 | -9/+25 |
* | [SPARK-14914][CORE] Fix Resource not closed after using, for unit tests and e... | wm624@hotmail.com | 2016-11-10 | 1 | -0/+2 |
* | [SPARK-17782][STREAMING][KAFKA] alternative eliminate race condition of poll ... | cody koeninger | 2016-10-12 | 1 | -5/+7 |
* | [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite tests | Adam Roberts | 2016-09-16 | 1 | -4/+4 |
* | [TEST][STREAMING] Fix flaky Kafka rate controlling test | Tathagata Das | 2016-07-26 | 1 | -5/+4 |
* | [SPARK-13569][STREAMING][KAFKA] pattern based topic subscription | cody koeninger | 2016-07-08 | 2 | -3/+86 |
* | [SPARK-12177][STREAMING][KAFKA] limit api surface area | cody koeninger | 2016-07-01 | 6 | -41/+64 |
* | [SPARK-12177][TEST] Removed test to avoid compilation issue in scala 2.10 | Tathagata Das | 2016-06-30 | 1 | -4/+4 |
* | [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum... | cody koeninger | 2016-06-29 | 7 | -0/+1253 |