You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by Grigoriy Rozhkov <gr...@gmail.com> on 2016/02/01 18:20:34 UTC

Re: Review Request 41702: Kafka Source supports kafka 0.9 consumer API

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41702/
-----------------------------------------------------------

(Updated Feb. 1, 2016, 5:20 p.m.)


Review request for Flume and Jeff Holoman.


Repository: flume-git


Description
-------

Kafka Source support for kafka 0.9


Diffs
-----

  flume-ng-doc/sphinx/FlumeUserGuide.rst 897a2ca14b485976bfe11d413423e1c8bb789745 
  flume-ng-sources/flume-kafka-source/pom.xml 0f93476c61e0281d45a15426493c4c3579503cee 
  flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java fd1dd3c17bda875daaecef02cd7c537bb14242b8 
  flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceConstants.java 911012cefcd656bac3308c3e02990a6ff42a0de5 
  flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java 26c5c9d0aa29fbbc1d9eced70b26aa3f81855c26 
  flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedZookeeper.java 1b8a27106e84b3ce1d8a100d31cf33d847c68f1b 
  flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java 8ec14cccf555ab38449b1bcb1e41a6ecbd19fe7c 
  pom.xml 15c086b5090305a1a70185626452a05cb7c1941d 

Diff: https://reviews.apache.org/r/41702/diff/


Testing
-------

New features:
- multiple topic subscription
Style for configuring new Kafka Source is made following styles in these patches.
https://reviews.apache.org/r/41626/
https://reviews.apache.org/r/41629/

generate command:
git diff --no-prefix --full-index > FLUME-2821.patch

apply command:
patch -p0 < FLUME-2821.patch


Thanks,

Grigoriy Rozhkov