diff --git a/src/connector/src/sink/log_store.rs b/src/connector/src/sink/log_store.rs index e1bc0a5ac0b70..8a37aea54a96a 100644 --- a/src/connector/src/sink/log_store.rs +++ b/src/connector/src/sink/log_store.rs @@ -557,6 +557,11 @@ impl LogReader for RateLimitedLogReader { 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 {