diff --git a/rust/processor/src/grpc_stream.rs b/rust/processor/src/grpc_stream.rs
index 23ed56733..5c0913b27 100644
--- a/rust/processor/src/grpc_stream.rs
+++ b/rust/processor/src/grpc_stream.rs
@@ -239,6 +239,7 @@ pub async fn get_chain_id(
     indexer_grpc_reconnection_timeout_secs: Duration,
     auth_token: String,
     processor_name: String,
+    starting_version_from_db: u64,
 ) -> u64 {
     info!(
         processor_name = processor_name,
@@ -251,8 +252,8 @@ pub async fn get_chain_id(
         indexer_grpc_http2_ping_interval,
         indexer_grpc_http2_ping_timeout,
         indexer_grpc_reconnection_timeout_secs,
-        1,
-        Some(2),
+        starting_version_from_db,
+        Some(starting_version_from_db + 1),
         auth_token.clone(),
         processor_name.to_string(),
     )
diff --git a/rust/processor/src/worker.rs b/rust/processor/src/worker.rs
index 389da017f..ac173b770 100644
--- a/rust/processor/src/worker.rs
+++ b/rust/processor/src/worker.rs
@@ -257,6 +257,7 @@ impl Worker {
             self.grpc_http2_config.grpc_connection_timeout_secs(),
             self.auth_token.clone(),
             processor_name.to_string(),
+            starting_version_from_db,
         )
         .await;
         self.check_or_update_chain_id(chain_id as i64)