aboutsummaryrefslogtreecommitdiff
path: root/external/kafka/src/test/java/org/apache
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-113-466/+0
* [SPARK-12073][STREAMING] backpressure rate controller consumes events prefere...Jason White2016-03-043-3/+3
* [SPARK-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-082-9/+6
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-123-27/+28
* [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...Sean Owen2015-08-041-1/+1
* [SPARK-8390] [STREAMING] [KAFKA] fix docs related to HasOffsetRangescody koeninger2015-06-191-1/+10
* [SPARK-8389] [STREAMING] [KAFKA] Example of getting offset ranges out o…cody koeninger2015-06-191-2/+13
* [SPARK-8404] [STREAMING] [TESTS] Use thread-safe collections to make the test...zsxwing2015-06-172-8/+4
* [SPARK-2808] [STREAMING] [KAFKA] cleanup tests fromcody koeninger2015-06-071-3/+0
* [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2cody koeninger2015-05-011-0/+3
* [SPARK-6211][Streaming] Add Python Kafka API unit testjerryshao2015-04-093-42/+48
* SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 editionSean Owen2015-03-113-34/+22
* [SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead o...cody koeninger2015-02-111-0/+156
* [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka streamTathagata Das2015-02-092-2/+162
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-141-18/+26
* [SPARK-3615][Streaming]Fix Kafka unit test hard coded Zookeeper port issuejerryshao2014-09-241-1/+1
* [SPARK-1022][Streaming] Add Kafka real unit testjerryshao2014-08-051-19/+106
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-211-4/+6
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-071-8/+3
* Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ...Tathagata Das2014-01-061-8/+7
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-301-0/+51
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-08 17:02:38 +0000