----------------------------------------------------------- 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
