This is an automated email from the ASF dual-hosted git repository.
tristan pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/flume.git
The following commit(s) were added to refs/heads/trunk by this push:
new 6fd373435 Set KafkaSink error message log level from DEBUG to WARN
(#388)
6fd373435 is described below
commit 6fd37343589b3b7bb5387100e45d9a7db7694527
Author: xuwang <[email protected]>
AuthorDate: Sun Oct 30 21:20:25 2022 +0800
Set KafkaSink error message log level from DEBUG to WARN (#388)
When send data to kafka error,log out exception message and set log level
from debug to warn，because in production environment log level usually be info
or higher level,debug level error message is invisible and we don't know lost
data when send data to kafka.
---
.../src/main/java/org/apache/flume/sink/kafka/KafkaSink.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
index b13d5b3b8..92014f0f4 100644
---
a/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
+++
b/flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
@@ -452,7 +452,7 @@ class SinkCallback implements Callback {
public void onCompletion(RecordMetadata metadata, Exception exception) {
if (exception != null) {
- logger.debug("Error sending message to Kafka {} ",
exception.getMessage());
+ logger.warn("Error sending message to Kafka {} ",
exception.getMessage());
}
if (logger.isDebugEnabled()) {
