-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15994/
-----------------------------------------------------------
Review request for Flume.
Bugs: Kafka and Source
https://issues.apache.org/jira/browse/Kafka
https://issues.apache.org/jira/browse/Source
Repository: flume-git
Description
-------
Add Kafka Source to flume-1.4, I'm using in our company for half year. In my
performance test, 100k message per second for 10 kafka sources is okay.
Diffs
-----
flume-ng-sources/flume-ng-kafka-source/pom.xml PRE-CREATION
flume-ng-sources/flume-ng-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
PRE-CREATION
flume-ng-sources/flume-ng-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceUtil.java
PRE-CREATION
flume-ng-sources/flume-ng-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceTest.java
PRE-CREATION
flume-ng-sources/flume-ng-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceUtilTest.java
PRE-CREATION
flume-ng-sources/flume-ng-kafka-source/src/test/resources/log4j.properties
PRE-CREATION
Diff: https://reviews.apache.org/r/15994/diff/
Testing
-------
Unitests are written whti JUnit and mockito.
Thanks,
Frank Yao
