Skip to content

Commit a5ff08c

Browse files
committed
Using trace for some verbose sink logging
"debug" is helpful on the source side for seeing some info on each poll call. But the "Processing record" message in the sink connector shows up for every single sink record; that can quickly become overwhelming. So shifted that to "trace".
1 parent 32b457e commit a5ff08c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/marklogic/kafka/connect/sink/AbstractSinkTask.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,8 +107,8 @@ private void logRecordBeforeWriting(SinkRecord sinkRecord) {
107107
sinkRecord.headers().forEach(header -> headers.add(String.format("%s:%s", header.key(), header.value().toString())));
108108
logger.info("Record headers: {}", headers);
109109
}
110-
if (logger.isDebugEnabled()) {
111-
logger.debug("Processing record value {} in topic {}", sinkRecord.value(), sinkRecord.topic());
110+
if (logger.isTraceEnabled()) {
111+
logger.trace("Processing record value {} in topic {}", sinkRecord.value(), sinkRecord.topic());
112112
}
113113
}
114114

0 commit comments

Comments
 (0)