fix: return early after ack handshake (#142)

Signed-off-by: Yashash H L <[email protected]>
numaproj · Sep 28, 2024 · c387f9a · c387f9a
1 parent f68f9f2
commit c387f9a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/io/numaproj/numaflow/sourcer/Service.java b/src/main/java/io/numaproj/numaflow/sourcer/Service.java
@@ -112,6 +112,7 @@ public void onNext(SourceOuterClass.AckRequest request) {
                             .setHandshake(request.getHandshake())
                             .build());
                     handshakeDone = true;
+                    return;
                 }
 
                 SourceOuterClass.Offset offset = request.getRequest().getOffset();