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

Posted to dev@flume.apache.org by deng kai <de...@baidu.com> on 2017/01/19 05:50:53 UTC

Review Request 55704: KafkaSink SinkCallback throws NullPointerException when Log4J level is debug

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

Review request for Flume.


Repository: flume-git


Description
-------

https://issues.apache.org/jira/browse/FLUME-3043?jql=project%20%3D%20FLUME

When we send a event with SinkCallback to kafka under DEBUG level of log4j, if kafka reponses a result with exception but not a RecordMetadata. Kafka Sink will throw NPE.


Diffs
-----

  flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java 241e900 

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


Testing
-------

All test passed.


Thanks,

deng kai