(doris-kafka-connector) branch master updated: [Improve] add log for record offset is smaller than processedOffset (#57)

[diwu]

This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-kafka-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 173a072  [Improve] add log for record offset is smaller than 
processedOffset (#57)
173a072 is described below

commit 173a07274948b60d7ebb33343b250e8cf2d72c91
Author: wudongliang <46414265+donglian...@users.noreply.github.com>
AuthorDate: Thu Dec 26 16:32:20 2024 +0800

    [Improve] add log for record offset is smaller than processedOffset (#57)
---
 .../java/org/apache/doris/kafka/connector/writer/DorisWriter.java   | 6 ++++++
 1 file changed, 6 insertions(+)

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 31938d9..2a6323d 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
@@ -135,6 +135,12 @@ public abstract class DorisWriter {
             if (tmpBuff != null) {
                 flush(tmpBuff);
             }
+        } else {
+            LOG.warn(
+                    "The record offset is smaller than processedOffset. 
recordOffset={}, offsetPersistedInDoris={}, processedOffset={}",
+                    record.kafkaOffset(),
+                    offsetPersistedInDoris.get(),
+                    processedOffset.get());
         }
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org