From 4c7174ba455011045443e74cfeac919053c657e4 Mon Sep 17 00:00:00 2001
From: Akram  Yakubov <akram.yakubov@gmail.com>
Date: Fri, 17 May 2024 10:40:14 -0700
Subject: [PATCH] Fix typo to send abort on abort instead of end

---
 .../binding/kafka/internal/stream/KafkaMergedFactory.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java b/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java
index 4ad471104e..9280cfef77 100644
--- a/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java
+++ b/runtime/binding-kafka/src/main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java
@@ -1341,7 +1341,7 @@ private void onMergedInitialAbort(
             describeStream.doDescribeInitialAbortIfNecessary(traceId);
             metaStream.doMetaInitialAbortIfNecessary(traceId);
             fetchStreams.forEach(f -> f.onMergedInitialAbort(traceId));
-            produceStreams.forEach(f -> f.doProduceInitialEndIfNecessary(traceId));
+            produceStreams.forEach(f -> f.doProduceInitialAbortIfNecessary(traceId));
 
             if (consumerStream != null)
             {