Xin Wang created FLUME-2846:
-------------------------------
Summary: flume-kafka-sink uses new kafka producer API
Key: FLUME-2846
URL: https://issues.apache.org/jira/browse/FLUME-2846
Project: Flume
Issue Type: Improvement
Components: Sinks+Sources
Affects Versions: v1.6.0
Reporter: Xin Wang
why use <a href="http://kafka.apache.org/documentation.html#producerapi";>new
producer API</a>?
because this new client is "both faster and more fully featured than the
previous Scala client".
changes are following:
1. add kafka-clients dependency to flume-parent/pom.xml and
flume-ng-kafka-sink.xml
2. use new producer api in KafkaSink
3. update producer configs in KafkaSinkConstants
4. update unit tests.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
