Unignore CacheMergedIT test methods

aklivity · Jun 11, 2024 · a5f7ff1 · a5f7ff1
1 parent 8b64c52
commit a5f7ff1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 7 deletions.
diff --git a/...main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java b/...main/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/KafkaMergedFactory.java
@@ -3645,8 +3645,7 @@ private void onFetchInitialReset(
             state = KafkaState.closedInitial(state);
 
             final KafkaResetExFW kafkaResetEx = extension.get(kafkaResetExRO::tryWrap);
-            final int defaultError = KafkaState.replyClosed(state) ? ERROR_NOT_LEADER_FOR_PARTITION : -1;
-            final int error = kafkaResetEx != null ? kafkaResetEx.error() : defaultError;
+            final int error = kafkaResetEx != null ? kafkaResetEx.error() : -1;
 
             doFetchReplyResetIfNecessary(traceId);
 

diff --git a/.../src/test/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/CacheMergedIT.java b/.../src/test/java/io/aklivity/zilla/runtime/binding/kafka/internal/stream/CacheMergedIT.java
@@ -70,7 +70,6 @@ public void shouldFetchMergedMessagesWithHeaderFilter() throws Exception
         k3po.finish();
     }
 
-    @Ignore("io.aklivity.k3po")
     @Test
     @Configuration("cache.options.merged.yaml")
     @Specification({
@@ -81,7 +80,6 @@ public void shouldFetchMergedMessagesWithHeaderFilterAfterCompaction() throws Ex
         k3po.finish();
     }
 
-    @Ignore("io.aklivity.k3po")
     @Test
     @Configuration("cache.options.merged.yaml")
     @Specification({
@@ -289,7 +287,6 @@ public void shouldFetchMergedFromParameterizedTopicInvalid() throws Exception
         k3po.finish();
     }
 
-    @Ignore("io.aklivity.k3po")
     @Test
     @Configuration("cache.options.validate.yaml")
     @Specification({
@@ -300,7 +297,6 @@ public void shouldFetchMergedMessageValueInvalid() throws Exception
         k3po.finish();
     }
 
-    @Ignore("io.aklivity.k3po")
     @Test
     @Configuration("cache.options.merged.yaml")
     @Specification({
@@ -315,7 +311,6 @@ public void shouldFetchMergedPartitionLeaderChanged() throws Exception
         k3po.finish();
     }
 
-    @Ignore("io.aklivity.k3po")
     @Test
     @Configuration("cache.options.merged.yaml")
     @Specification({