Skip to content

Commit 4c65569

Browse files
authored
[Chore] change log level to debug (#75)
1 parent 0813cb5 commit 4c65569

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -138,11 +138,13 @@ protected void insertRecord(final SinkRecord record) {
138138
}
139139
processedOffset.set(dorisRecord.kafkaOffset());
140140
} else {
141-
LOG.warn(
142-
"The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
143-
record.kafkaOffset(),
144-
offsetPersistedInDoris.get(),
145-
processedOffset.get());
141+
if (LOG.isDebugEnabled()) {
142+
LOG.debug(
143+
"The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
144+
record.kafkaOffset(),
145+
offsetPersistedInDoris.get(),
146+
processedOffset.get());
147+
}
146148
}
147149
}
148150

0 commit comments

Comments
 (0)