add trace logs

risingwavelabs · Dec 18, 2024 · 11e522e · 11e522e
1 parent 6d95206
commit 11e522e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/connector/src/sink/log_store.rs b/src/connector/src/sink/log_store.rs
@@ -557,6 +557,11 @@ impl<R: LogReader> LogReader for RateLimitedLogReader<R> {
                 break;
             }
         }
+        tracing::trace!(
+            "rate limited log store reader truncate offset {:?}, downstream offset {:?}",
+            truncate_offset,
+            offset
+        );
         if let Some(offset) = truncate_offset {
             self.core.inner.truncate(offset)
         } else {