Skip to content

Commit 692e2de

Browse files
committed
update
1 parent da90442 commit 692e2de

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
@@ -141,11 +141,13 @@ protected void insertRecord(final SinkRecord record) {
141141
}
142142
processedOffset.set(dorisRecord.kafkaOffset());
143143
} else {
144-
LOG.debug(
145-
"The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
146-
record.kafkaOffset(),
147-
offsetPersistedInDoris.get(),
148-
processedOffset.get());
144+
if (LOG.isDebugEnabled()) {
145+
LOG.debug(
146+
"The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
147+
record.kafkaOffset(),
148+
offsetPersistedInDoris.get(),
149+
processedOffset.get());
150+
}
149151
}
150152
}
151153

0 commit comments

Comments
 (0)