align the semantics of scan.startup.mode=latest of nats with others

risingwavelabs · Sep 27, 2024 · 068e65d · 068e65d
1 parent 83fe9f3
commit 068e65d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/connector/src/connector_common/common.rs b/src/connector/src/connector_common/common.rs
@@ -664,7 +664,7 @@ impl NatsCommon {
 
         let deliver_policy = match start_sequence {
             NatsOffset::Earliest => DeliverPolicy::All,
-            NatsOffset::Latest => DeliverPolicy::Last,
+            NatsOffset::Latest => DeliverPolicy::New,
             NatsOffset::SequenceNumber(v) => {
                 let parsed = v
                     .parse::<u64>()