fix

risingwavelabs · Mar 14, 2024 · 36bc335 · 36bc335
1 parent 59ae1cf
commit 36bc335
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/connector/src/parser/mod.rs b/src/connector/src/parser/mod.rs
@@ -657,8 +657,7 @@ async fn into_chunk_stream<P: ByteStreamSourceParser>(mut parser: P, data_stream
         let process_time_ms = chrono::Utc::now().timestamp_millis();
         for (i, msg) in batch.into_iter().enumerate() {
             if msg.key.is_none() && msg.payload.is_none() {
-                tracing::debug!(offset = msg.offset, "skip parsing of heartbeat message");
-                continue;
+                tracing::debug!(offset = msg.offset, "got a empty message, could be a heartbeat");
             }
 
             // calculate process_time - event_time lag