----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/15995/ -----------------------------------------------------------
Review request for Flume. Repository: flume-git Description ------- Add Kafka(0.7.2) 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-sinks/flume-ng-kafka-sink/pom.xml PRE-CREATION flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java PRE-CREATION flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkUtil.java PRE-CREATION flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/KafkaSinkTest.java PRE-CREATION flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/KafkaSinkUtilTest.java PRE-CREATION flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/log4j.properties PRE-CREATION Diff: https://reviews.apache.org/r/15995/diff/ Testing ------- Unitests are written whti JUnit and mockito. Thanks, Frank Yao
