change log level to debug

JNSimba · web-flow · commit da9044240ef8 · 2025-05-26T10:35:32.000+08:00
diff --git a/src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java b/src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java
@@ -141,7 +141,7 @@ protected void insertRecord(final SinkRecord record) {
             }
             processedOffset.set(dorisRecord.kafkaOffset());
         } else {
-            LOG.warn(
+            LOG.debug(
                     "The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
                     record.kafkaOffset(),
                     offsetPersistedInDoris.get(),

Original file line number	Diff line number	Diff line change
`@@ -141,7 +141,7 @@ protected void insertRecord(final SinkRecord record) {`
`141`	`141`	`}`
`142`	`142`	`processedOffset.set(dorisRecord.kafkaOffset());`
`143`	`143`	`} else {`
`144`		`- LOG.warn(`
	`144`	`+ LOG.debug(`
`145`	`145`	`"The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",`
`146`	`146`	`record.kafkaOffset(),`
`147`	`147`	`offsetPersistedInDoris.get(),`