Fix build breakage caused by KAFKA-14334 (#1083)

KAFKA-14334 changed a kafka.utils.TestUtils method by adding a default argument (Scala). Unfortunately this is a breaking change for Java downstream dependencies.
confluentinc · Nov 17, 2022 · f4451aa · f4451aa
1 parent cbf461f
commit f4451aa
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/kafka-rest/src/test/java/io/confluent/kafkarest/integration/AuthorizationErrorTest.java b/kafka-rest/src/test/java/io/confluent/kafkarest/integration/AuthorizationErrorTest.java
@@ -107,7 +107,8 @@ protected Properties getBrokerProperties(int i) {
             1,
             false,
             1,
-            (short) 1);
+            (short) 1,
+            false);
     brokerProps.put(KafkaConfig.BrokerIdProp(), Integer.toString(i));
     brokerProps.put(KafkaConfig.ZkConnectProp(), zkConnect);
     brokerProps.setProperty("authorizer.class.name", AclAuthorizer.class.getName());

diff --git a/kafka-rest/src/test/java/io/confluent/kafkarest/integration/ClusterTestHarness.java b/kafka-rest/src/test/java/io/confluent/kafkarest/integration/ClusterTestHarness.java
@@ -333,7 +333,8 @@ protected Properties getBrokerProperties(int i) {
             1,
             false,
             1,
-            (short) 1);
+            (short) 1,
+            false);
     props.setProperty("auto.create.topics.enable", "false");
     // We *must* override this to use the port we allocated (Kafka currently allocates one port
     // that it always uses for ZK