This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch JNSimba-patch-2 in repository https://gitbox.apache.org/repos/asf/doris-kafka-connector.git
commit da9044240ef80438fdbd8c3ed592f837cd4c5555 Author: wudi <[email protected]> AuthorDate: Mon May 26 10:35:32 2025 +0800 change log level to debug --- src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 9e5cfb9..64a4b5a 100644 --- 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 @@ public abstract class DorisWriter { } processedOffset.set(dorisRecord.kafkaOffset()); } else { - LOG.warn( + LOG.debug( "The record offset is smaller than processedOffset. recordOffset={}, offsetPersistedInDoris={}, processedOffset={}", record.kafkaOffset(), offsetPersistedInDoris.get(), --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
