fix bug

TaiJuWu · Nov 23, 2024 · bcd46cf · bcd46cf
1 parent c6bbb34
commit bcd46cf
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/tools/src/test/java/org/apache/kafka/tools/TopicCommandTest.java b/tools/src/test/java/org/apache/kafka/tools/TopicCommandTest.java
@@ -59,6 +59,7 @@
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.apache.kafka.common.test.api.ClusterConfig;
+import org.apache.kafka.common.test.api.ClusterConfigProperty;
 import org.apache.kafka.common.test.api.ClusterInstance;
 import org.apache.kafka.common.test.api.ClusterTemplate;
 import org.apache.kafka.common.test.api.ClusterTest;
@@ -1352,9 +1353,12 @@ public void testDescribeDoesNotFailWhenListingReassignmentIsUnauthorized(Cluster
         adminClient.close();
     }
 
-    @ClusterTest
+    @ClusterTest(
+            serverProperties = {
+                @ClusterConfigProperty(key = "offsets.topic.replication.factor", value = "1")
+            }
+    )
     public void testDiffCompressionProdcueSend(ClusterInstance clusterInstance) throws InterruptedException, ExecutionException {
-        clusterInstance.waitForReadyBrokers();
         clusterInstance.createTopic("test", 1, (short) 1);
         clusterInstance.createTopic("topic", 1, (short) 1);
         Map<String, Object> producerProps = new HashMap<>();