(kafka) branch trunk updated: KAFKA-13531: Disable flaky NamedTopologyIntegrationTest (#14830)

[lu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lucasbru pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new fe58cb1ebdd KAFKA-13531: Disable flaky NamedTopologyIntegrationTest (#14830)
fe58cb1ebdd is described below

commit fe58cb1ebdd748118efcdbabe61da2098fada0d2
Author: Lucas Brutschy <lb...@confluent.io>
AuthorDate: Fri Nov 24 10:44:25 2023 +0100

    KAFKA-13531: Disable flaky NamedTopologyIntegrationTest (#14830)
    
    Named topologies is a feature that is planned to be removed from AK with 4.0 and was never used via the public interface. It was used in a few versions of KSQL only, but was disabled there as well. While we do not want to remove it in 3.7 yet, we should disable flaky tests in that feature, that are disruptive to AK development.
    
    Reviewers: Bruno Cadonna <ca...@apache.org>
---
 .../kafka/streams/integration/NamedTopologyIntegrationTest.java       | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
index ee290211b6d..3588d8a3b12 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
@@ -64,6 +64,7 @@ import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.Map;
 import java.util.Queue;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeAll;
@@ -347,6 +348,7 @@ public class NamedTopologyIntegrationTest {
     }
 
     @Test
+    @Disabled
     public void shouldAddAndRemoveNamedTopologiesBeforeStartingAndRouteQueriesToCorrectTopology() throws Exception {
         try {
             // for this test we have one of the topologies read from an input topic with just one partition so
@@ -444,6 +446,7 @@ public class NamedTopologyIntegrationTest {
     }
 
     @Test
+    @Disabled
     public void shouldAddNamedTopologyToRunningApplicationWithSingleInitialNamedTopology() throws Exception {
         topology1Builder.stream(INPUT_STREAM_1).groupBy((k, v) -> k).count(IN_MEMORY_STORE).toStream().to(OUTPUT_STREAM_1);
         topology2Builder.stream(INPUT_STREAM_2).groupBy((k, v) -> k).count(IN_MEMORY_STORE).toStream().to(OUTPUT_STREAM_2);
@@ -458,6 +461,7 @@ public class NamedTopologyIntegrationTest {
     }
 
     @Test
+    @Disabled
     public void shouldAddNamedTopologyToRunningApplicationWithMultipleInitialNamedTopologies() throws Exception {
         topology1Builder.stream(INPUT_STREAM_1).groupBy((k, v) -> k).count(ROCKSDB_STORE).toStream().to(OUTPUT_STREAM_1);
         topology2Builder.stream(INPUT_STREAM_2).groupBy((k, v) -> k).count(ROCKSDB_STORE).toStream().to(OUTPUT_STREAM_2);