fix deprecated function

Signed-off-by: Runji Wang <[email protected]>
risingwavelabs · Sep 18, 2023 · bc2474b · bc2474b
1 parent 16a2e9f
commit bc2474b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/connector/src/source/google_pubsub/source/message.rs b/src/connector/src/source/google_pubsub/source/message.rs
@@ -50,7 +50,7 @@ impl From<TaggedReceivedMessage> for SourceMessage {
                     _ => Some(payload),
                 }
             },
-            offset: timestamp.timestamp_nanos().to_string(),
+            offset: timestamp.timestamp_nanos_opt().unwrap().to_string(),
             split_id,
             meta: SourceMeta::GooglePubsub(GooglePubsubMeta {
                 timestamp: Some(timestamp.timestamp_millis()),