diff --git a/.checkstyle/suppressions.xml b/.checkstyle/suppressions.xml
index 31604c11311..bf2c33e5cac 100644
--- a/.checkstyle/suppressions.xml
+++ b/.checkstyle/suppressions.xml
@@ -39,7 +39,7 @@
-
-
+
+
\ No newline at end of file
diff --git a/api/pom.xml b/api/pom.xml
index c7d1109f02e..40971a51732 100644
--- a/api/pom.xml
+++ b/api/pom.xml
@@ -62,11 +62,6 @@
com.fasterxml.jackson.core
jackson-databind
-
- com.fasterxml.jackson.dataformat
- jackson-dataformat-yaml
- test
-
io.sundr
builder-annotations
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdIT.java
index 22ed45870d0..796ddbe5f04 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdIT.java
@@ -6,7 +6,7 @@
import io.fabric8.kubernetes.client.CustomResource;
import io.fabric8.kubernetes.client.KubernetesClient;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import io.strimzi.test.interfaces.TestSeparator;
import org.junit.jupiter.api.TestInstance;
@@ -62,11 +62,11 @@ private void createDelete(File resourceFile) {
}
protected void createScaleDelete(Class resourceClass, String resource) {
- T model = TestUtils.fromYaml(resource, resourceClass);
+ T model = ReadWriteUtils.readObjectFromYamlFileInResources(resource, resourceClass);
String apiVersion = model.getApiVersion();
String kind = model.getKind();
String resourceName = model.getMetadata().getName();
- String resourceYamlAsString = TestUtils.toYamlString(model);
+ String resourceYamlAsString = ReadWriteUtils.writeObjectToYamlString(model);
createScaleDelete(apiVersion, kind, resourceName, resourceYamlAsString);
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdTest.java b/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdTest.java
index bb45ba8fc6f..af317ac3822 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdTest.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/AbstractCrdTest.java
@@ -6,7 +6,7 @@
import io.fabric8.kubernetes.api.model.ObjectMeta;
import io.fabric8.kubernetes.client.CustomResource;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.is;
@@ -24,23 +24,23 @@ protected AbstractCrdTest(Class crdClass) {
}
protected void assertDesiredResource(R actual, String expectedResource) {
- String content = TestUtils.readResource(getClass(), expectedResource);
+ String content = ReadWriteUtils.readFileFromResources(getClass(), expectedResource);
assertThat("The resource " + expectedResource + " does not exist", content, is(notNullValue()));
- String ssStr = TestUtils.toYamlString(actual);
+ String ssStr = ReadWriteUtils.writeObjectToYamlString(actual);
assertThat(ssStr.trim(), is(content.trim()));
}
@Test
public void roundTrip() {
String resourceName = crdClass.getSimpleName() + ".yaml";
- R model = TestUtils.fromYaml(resourceName, crdClass);
+ R model = ReadWriteUtils.readObjectFromYamlFileInResources(resourceName, crdClass);
assertThat("The classpath resource " + resourceName + " does not exist", model, is(notNullValue()));
ObjectMeta metadata = model.getMetadata();
assertThat(metadata, is(notNullValue()));
assertDesiredResource(model, crdClass.getSimpleName() + ".out.yaml");
- assertDesiredResource(TestUtils.fromYamlString(TestUtils.toYamlString(model), crdClass), crdClass.getSimpleName() + ".out.yaml");
+ assertDesiredResource(ReadWriteUtils.readObjectFromYamlString(ReadWriteUtils.writeObjectToYamlString(model), crdClass), crdClass.getSimpleName() + ".out.yaml");
}
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/ExamplesTest.java b/api/src/test/java/io/strimzi/api/kafka/model/ExamplesTest.java
index 59f52a2af7a..d2588846beb 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/ExamplesTest.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/ExamplesTest.java
@@ -5,11 +5,10 @@
package io.strimzi.api.kafka.model;
import com.fasterxml.jackson.annotation.JsonAnyGetter;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.dataformat.yaml.YAMLMapper;
import io.fabric8.kubernetes.api.model.KubernetesResource;
import io.fabric8.kubernetes.api.model.apiextensions.v1.CustomResourceDefinitionSpec;
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
+import io.strimzi.test.ReadWriteUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.Test;
@@ -25,7 +24,6 @@
import static org.junit.jupiter.api.Assertions.fail;
-
/**
* The purpose of this test is to check that all the resources in the
* {@code ../packaging/examples} directory are valid.
@@ -57,8 +55,7 @@ private void validateRecursively(File directory) {
private void validate(File f) {
try {
- ObjectMapper mapper = new YAMLMapper();
- final String content = TestUtils.readFile(f);
+ final String content = ReadWriteUtils.readFile(f);
validate(content);
} catch (Exception | AssertionError e) {
throw new AssertionError("Invalid example yaml in " + f.getPath() + ": " + e.getMessage(), e);
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/JvmOptionsTest.java b/api/src/test/java/io/strimzi/api/kafka/model/JvmOptionsTest.java
index 747984f700c..1d0db01c664 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/JvmOptionsTest.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/JvmOptionsTest.java
@@ -5,16 +5,19 @@
package io.strimzi.api.kafka.model;
import io.strimzi.api.kafka.model.common.JvmOptions;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import org.junit.jupiter.api.Test;
+import java.util.Map;
+
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.nullValue;
import static org.hamcrest.MatcherAssert.assertThat;
+
public class JvmOptionsTest {
@Test
public void testSetXmxXms() {
- JvmOptions opts = TestUtils.fromYamlString("-Xmx: 2g\n" +
+ JvmOptions opts = ReadWriteUtils.readObjectFromYamlString("-Xmx: 2g\n" +
"-Xms: 1g",
JvmOptions.class);
@@ -24,7 +27,7 @@ public void testSetXmxXms() {
@Test
public void testEmptyXmxXms() {
- JvmOptions opts = TestUtils.fromYamlString("{}", JvmOptions.class);
+ JvmOptions opts = ReadWriteUtils.readObjectFromYamlString("{}", JvmOptions.class);
assertThat(opts.getXms(), is(nullValue()));
assertThat(opts.getXmx(), is(nullValue()));
@@ -32,7 +35,7 @@ public void testEmptyXmxXms() {
@Test
public void testXx() {
- JvmOptions opts = TestUtils.fromYamlString("-XX:\n" +
+ JvmOptions opts = ReadWriteUtils.readObjectFromYamlString("-XX:\n" +
" key1: value1\n" +
" key2: value2\n" +
" key3: true\n" +
@@ -40,9 +43,9 @@ public void testXx() {
" key5: 10\n",
JvmOptions.class);
- assertThat(opts.getXx(), is(TestUtils.map("key1", "value1", "key2", "value2", "key3", "true", "key4", "true", "key5", "10")));
+ assertThat(opts.getXx(), is(Map.of("key1", "value1", "key2", "value2", "key3", "true", "key4", "true", "key5", "10")));
- opts = TestUtils.fromYamlString("{}", JvmOptions.class);
+ opts = ReadWriteUtils.readObjectFromYamlString("{}", JvmOptions.class);
assertThat(opts.getXx(), is(nullValue()));
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/KafkaJmxOptionsTest.java b/api/src/test/java/io/strimzi/api/kafka/model/KafkaJmxOptionsTest.java
index 6fdbcc3d852..db7daddd10b 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/KafkaJmxOptionsTest.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/KafkaJmxOptionsTest.java
@@ -6,7 +6,7 @@
import io.strimzi.api.kafka.model.common.jmx.KafkaJmxAuthenticationPassword;
import io.strimzi.api.kafka.model.common.jmx.KafkaJmxOptions;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import org.junit.jupiter.api.Test;
import java.util.Collections;
@@ -20,7 +20,7 @@
public class KafkaJmxOptionsTest {
@Test
public void testAuthentication() {
- KafkaJmxOptions opts = TestUtils.fromYamlString(
+ KafkaJmxOptions opts = ReadWriteUtils.readObjectFromYamlString(
"authentication:\n" +
" type: password",
KafkaJmxOptions.class);
@@ -31,7 +31,7 @@ public void testAuthentication() {
@Test
public void testNoJmxOpts() {
- KafkaJmxOptions opts = TestUtils.fromYamlString("{}", KafkaJmxOptions.class);
+ KafkaJmxOptions opts = ReadWriteUtils.readObjectFromYamlString("{}", KafkaJmxOptions.class);
assertThat(opts.getAuthentication(), is(nullValue()));
assertThat(opts.getAdditionalProperties(), is(Collections.emptyMap()));
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/StructuralCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/StructuralCrdIT.java
index 5b017e79251..6942aecaf42 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/StructuralCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/StructuralCrdIT.java
@@ -10,6 +10,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.strimzi.api.annotations.ApiVersion;
import io.strimzi.api.annotations.VersionRange;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
@@ -59,10 +60,10 @@ public void v1Beta2IsStructuralWithCrdV1() {
private void assertApiVersionsAreStructural(String crdName, String crdPath, VersionRange shouldBeStructural) {
try {
- TestUtils.createCrd(client, crdName, crdPath);
+ CrdUtils.createCrd(client, crdName, crdPath);
assertApiVersionsAreStructuralInApiextensionsV1(crdName, shouldBeStructural);
} finally {
- TestUtils.deleteCrd(client, crdName);
+ CrdUtils.deleteCrd(client, crdName);
}
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/bridge/KafkaBridgeCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/bridge/KafkaBridgeCrdIT.java
index eb7f1fa7e97..b4968bea861 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/bridge/KafkaBridgeCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/bridge/KafkaBridgeCrdIT.java
@@ -8,6 +8,8 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
+import io.strimzi.test.ReadWriteUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -85,7 +87,7 @@ void testKafkaBridgeWithOpenTelemetryTracing() {
void testLoadKafkaBridgeWithWrongTracingType() {
Throwable exception = assertThrows(
RuntimeException.class,
- () -> TestUtils.fromYaml("KafkaBridge-with-wrong-tracing-type.yaml", KafkaBridge.class));
+ () -> ReadWriteUtils.readObjectFromYamlFileInResources("KafkaBridge-with-wrong-tracing-type.yaml", KafkaBridge.class));
assertThat(exception.getMessage(), allOf(
containsStringIgnoringCase("Could not resolve type id 'wrongtype'"),
@@ -119,13 +121,13 @@ void testKafkaBridgeWithMetrics() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaBridge.CRD_NAME, TestUtils.CRD_KAFKA_BRIDGE);
+ CrdUtils.createCrd(client, KafkaBridge.CRD_NAME, CrdUtils.CRD_KAFKA_BRIDGE);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaBridge.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaBridge.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/connect/KafkaConnectCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/connect/KafkaConnectCrdIT.java
index adeaa961788..c6cb3c2eb32 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/connect/KafkaConnectCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/connect/KafkaConnectCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -100,13 +101,13 @@ void testKafkaConnectWithInvalidExternalConfiguration() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaConnect.CRD_NAME, TestUtils.CRD_KAFKA_CONNECT);
+ CrdUtils.createCrd(client, KafkaConnect.CRD_NAME, CrdUtils.CRD_KAFKA_CONNECT);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaConnect.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaConnect.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/connector/KafkaConnectorCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/connector/KafkaConnectorCrdIT.java
index 63eb6ae4b0b..d600ed8284d 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/connector/KafkaConnectorCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/connector/KafkaConnectorCrdIT.java
@@ -7,6 +7,7 @@
import io.fabric8.kubernetes.client.ConfigBuilder;
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -34,13 +35,13 @@ void testKafkaConnectorScaling() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaConnector.CRD_NAME, TestUtils.CRD_KAFKA_CONNECTOR);
+ CrdUtils.createCrd(client, KafkaConnector.CRD_NAME, CrdUtils.CRD_KAFKA_CONNECTOR);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaConnector.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaConnector.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaCrdIT.java
index ed81beb0d05..0331e0279b2 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -113,13 +114,13 @@ public void testKafkaWithInvalidZookeeperJmxAuthentication() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, Kafka.CRD_NAME, TestUtils.CRD_KAFKA);
+ CrdUtils.createCrd(client, Kafka.CRD_NAME, CrdUtils.CRD_KAFKA);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, Kafka.CRD_NAME);
+ CrdUtils.deleteCrd(client, Kafka.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaTest.java b/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaTest.java
index ca7edd6f8a8..8e64e7abbfa 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaTest.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/kafka/KafkaTest.java
@@ -12,7 +12,7 @@
import io.strimzi.api.kafka.model.kafka.listener.ListenerAddressBuilder;
import io.strimzi.api.kafka.model.kafka.listener.ListenerStatus;
import io.strimzi.api.kafka.model.kafka.listener.ListenerStatusBuilder;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import org.junit.jupiter.api.Test;
import java.net.URISyntaxException;
@@ -80,7 +80,7 @@ public void testCertificationAuthorityBuilderAndInts() throws URISyntaxException
.build();
String path = Objects.requireNonNull(this.getClass().getResource("Kafka-ca-ints.yaml")).toURI().getPath();
- assertThat(TestUtils.toYamlString(kafka), is(TestUtils.getFileAsString(path)));
+ assertThat(ReadWriteUtils.writeObjectToYamlString(kafka), is(ReadWriteUtils.readFile(path)));
}
@Test
@@ -121,12 +121,12 @@ public void testNewListenerSerialization() throws URISyntaxException {
.build();
String path = Objects.requireNonNull(this.getClass().getResource("Kafka-new-listener-serialization.yaml")).toURI().getPath();
- assertThat(TestUtils.toYamlString(kafka), is(TestUtils.getFileAsString(path)));
+ assertThat(ReadWriteUtils.writeObjectToYamlString(kafka), is(ReadWriteUtils.readFile(path)));
}
@Test
public void testListeners() {
- Kafka model = TestUtils.fromYaml("Kafka" + ".yaml", Kafka.class);
+ Kafka model = ReadWriteUtils.readObjectFromYamlFileInResources("Kafka" + ".yaml", Kafka.class);
assertThat(model.getSpec().getKafka().getListeners(), is(notNullValue()));
assertThat(model.getSpec().getKafka().getListeners().size(), is(2));
@@ -188,12 +188,12 @@ public void testListenerTypeAndNameInStatus() throws ParseException, URISyntaxEx
.build();
String path = Objects.requireNonNull(this.getClass().getResource("Kafka-listener-name-and-status.yaml")).toURI().getPath();
- assertThat(TestUtils.toYamlString(kafka), is(TestUtils.getFileAsString(path)));
+ assertThat(ReadWriteUtils.writeObjectToYamlString(kafka), is(ReadWriteUtils.readFile(path)));
}
@Test
public void testListenersTypeAndName() {
- Kafka model = TestUtils.fromYaml("Kafka-listener-name-and-status" + ".yaml", Kafka.class);
+ Kafka model = ReadWriteUtils.readObjectFromYamlFileInResources("Kafka-listener-name-and-status" + ".yaml", Kafka.class);
assertThat(model.getStatus().getListeners(), is(notNullValue()));
assertThat(model.getStatus().getListeners().size(), is(2));
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker/KafkaMirrorMakerCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker/KafkaMirrorMakerCrdIT.java
index 6acb20a26c8..0618972ae79 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker/KafkaMirrorMakerCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker/KafkaMirrorMakerCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -84,14 +85,14 @@ void testKafkaMirrorMakerWithCommitAndAbort() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaMirrorMaker.CRD_NAME, TestUtils.CRD_KAFKA_MIRROR_MAKER);
+ CrdUtils.createCrd(client, KafkaMirrorMaker.CRD_NAME, CrdUtils.CRD_KAFKA_MIRROR_MAKER);
TestUtils.createNamespace(client, NAMESPACE);
}
@SuppressWarnings("deprecation") // Kafka Mirror Maker is deprecated
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaMirrorMaker.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaMirrorMaker.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker2/KafkaMirrorMaker2CrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker2/KafkaMirrorMaker2CrdIT.java
index 9917e681799..3e6fdb38757 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker2/KafkaMirrorMaker2CrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/mirrormaker2/KafkaMirrorMaker2CrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -100,13 +101,13 @@ public void testKafkaMirrorMaker2WithInvalidExternalConfiguration() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaMirrorMaker2.CRD_NAME, TestUtils.CRD_KAFKA_MIRROR_MAKER_2);
+ CrdUtils.createCrd(client, KafkaMirrorMaker2.CRD_NAME, CrdUtils.CRD_KAFKA_MIRROR_MAKER_2);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaMirrorMaker2.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaMirrorMaker2.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/nodepool/KafkaNodePoolCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/nodepool/KafkaNodePoolCrdIT.java
index 83fe88cc2cb..9e9f87826e2 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/nodepool/KafkaNodePoolCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/nodepool/KafkaNodePoolCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -45,13 +46,13 @@ public void testKafkaWithInvalidRole() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaNodePool.CRD_NAME, TestUtils.CRD_KAFKA_NODE_POOL);
+ CrdUtils.createCrd(client, KafkaNodePool.CRD_NAME, CrdUtils.CRD_KAFKA_NODE_POOL);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaNodePool.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaNodePool.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/podset/StrimziPodSetCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/podset/StrimziPodSetCrdIT.java
index a8be0f0b0e4..511db06348c 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/podset/StrimziPodSetCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/podset/StrimziPodSetCrdIT.java
@@ -11,6 +11,7 @@
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.Crds;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -71,13 +72,13 @@ void testZeroReplicas() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, StrimziPodSet.CRD_NAME, TestUtils.CRD_STRIMZI_POD_SET);
+ CrdUtils.createCrd(client, StrimziPodSet.CRD_NAME, CrdUtils.CRD_STRIMZI_POD_SET);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, StrimziPodSet.CRD_NAME);
+ CrdUtils.deleteCrd(client, StrimziPodSet.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/rebalance/KafkaRebalanceCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/rebalance/KafkaRebalanceCrdIT.java
index dfc3bf4b4e7..25e39525305 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/rebalance/KafkaRebalanceCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/rebalance/KafkaRebalanceCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -78,13 +79,13 @@ void testKafkaRebalanceWrongMode() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaRebalance.CRD_NAME, TestUtils.CRD_KAFKA_REBALANCE);
+ CrdUtils.createCrd(client, KafkaRebalance.CRD_NAME, CrdUtils.CRD_KAFKA_REBALANCE);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaRebalance.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaRebalance.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/topic/KafkaTopicCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/topic/KafkaTopicCrdIT.java
index 8b74c8f3fb9..24594f254a3 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/topic/KafkaTopicCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/topic/KafkaTopicCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -47,13 +48,13 @@ void testKafkaTopicMinimal() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaTopic.CRD_NAME, TestUtils.CRD_TOPIC);
+ CrdUtils.createCrd(client, KafkaTopic.CRD_NAME, CrdUtils.CRD_TOPIC);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaTopic.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaTopic.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/api/src/test/java/io/strimzi/api/kafka/model/user/KafkaUserCrdIT.java b/api/src/test/java/io/strimzi/api/kafka/model/user/KafkaUserCrdIT.java
index a9719a9113e..f787d03e07d 100644
--- a/api/src/test/java/io/strimzi/api/kafka/model/user/KafkaUserCrdIT.java
+++ b/api/src/test/java/io/strimzi/api/kafka/model/user/KafkaUserCrdIT.java
@@ -8,6 +8,7 @@
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
import io.fabric8.kubernetes.client.KubernetesClientException;
import io.strimzi.api.kafka.model.AbstractCrdIT;
+import io.strimzi.test.CrdUtils;
import io.strimzi.test.TestUtils;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
@@ -47,13 +48,13 @@ void testKafkaUserMinimal() {
@BeforeAll
void setupEnvironment() {
client = new KubernetesClientBuilder().withConfig(new ConfigBuilder().withNamespace(NAMESPACE).build()).build();
- TestUtils.createCrd(client, KafkaUser.CRD_NAME, TestUtils.CRD_KAFKA_USER);
+ CrdUtils.createCrd(client, KafkaUser.CRD_NAME, CrdUtils.CRD_KAFKA_USER);
TestUtils.createNamespace(client, NAMESPACE);
}
@AfterAll
void teardownEnvironment() {
- TestUtils.deleteCrd(client, KafkaUser.CRD_NAME);
+ CrdUtils.deleteCrd(client, KafkaUser.CRD_NAME);
TestUtils.deleteNamespace(client, NAMESPACE);
client.close();
}
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/ResourceUtils.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/ResourceUtils.java
index d7810f743de..6de9e54ab88 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/ResourceUtils.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/ResourceUtils.java
@@ -83,7 +83,6 @@
import io.strimzi.operator.common.auth.PemTrustSet;
import io.strimzi.operator.common.model.Ca;
import io.strimzi.operator.common.model.Labels;
-import io.strimzi.test.TestUtils;
import io.vertx.core.Future;
import io.vertx.core.Vertx;
import io.vertx.core.net.NetClientOptions;
@@ -186,7 +185,7 @@ public static Kafka createKafka(String namespace, String name, int replicas,
ObjectMeta meta = new ObjectMetaBuilder()
.withNamespace(namespace)
.withName(name)
- .withLabels(Labels.fromMap(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests", "my-user-label", "cromulent")).toMap())
+ .withLabels(Labels.fromMap(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests", "my-user-label", "cromulent")).toMap())
.build();
result.setMetadata(meta);
@@ -245,7 +244,7 @@ public static KafkaConnect createEmptyKafkaConnect(String namespace, String name
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.withAnnotations(emptyMap())
.build())
@@ -262,7 +261,7 @@ public static KafkaBridge createEmptyKafkaBridge(String namespace, String name)
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.build())
.withNewSpec()
@@ -280,7 +279,7 @@ public static KafkaMirrorMaker createEmptyKafkaMirrorMaker(String namespace, Str
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.build())
.withNewSpec()
@@ -303,7 +302,7 @@ public static KafkaMirrorMaker createKafkaMirrorMaker(String namespace, String n
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.build())
.withNewSpec()
@@ -327,7 +326,7 @@ public static KafkaBridge createKafkaBridge(String namespace, String name, Strin
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.build())
.withNewSpec()
@@ -350,7 +349,7 @@ public static KafkaMirrorMaker2 createEmptyKafkaMirrorMaker2(String namespace, S
.withMetadata(new ObjectMetaBuilder()
.withName(name)
.withNamespace(namespace)
- .withLabels(TestUtils.map(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
+ .withLabels(Map.of(Labels.KUBERNETES_DOMAIN + "part-of", "tests",
"my-user-label", "cromulent"))
.build())
.withNewSpec()
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/AbstractModelTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/AbstractModelTest.java
index 856578954cc..a3d5a4148bd 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/AbstractModelTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/AbstractModelTest.java
@@ -11,7 +11,7 @@
import io.strimzi.api.kafka.model.kafka.Kafka;
import io.strimzi.api.kafka.model.kafka.KafkaBuilder;
import io.strimzi.operator.common.Reconciliation;
-import io.strimzi.test.TestUtils;
+import io.strimzi.test.ReadWriteUtils;
import io.strimzi.test.annotations.ParallelSuite;
import io.strimzi.test.annotations.ParallelTest;
@@ -37,11 +37,11 @@ public Model(HasMetadata resource) {
@ParallelTest
public void testJvmPerformanceOptions() {
- JvmOptions opts = TestUtils.fromYamlString("{}", JvmOptions.class);
+ JvmOptions opts = ReadWriteUtils.readObjectFromYamlString("{}", JvmOptions.class);
assertThat(getPerformanceOptions(opts), is(nullValue()));
- opts = TestUtils.fromYamlString("-XX:\n" +
+ opts = ReadWriteUtils.readObjectFromYamlString("-XX:\n" +
" key1: value1\n" +
" key2: true\n" +
" key3: false\n" +
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/CruiseControlTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/CruiseControlTest.java
index b4ca620959b..baafe83c4e7 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/CruiseControlTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/CruiseControlTest.java
@@ -564,17 +564,17 @@ public void testGenerateService() {
@SuppressWarnings("MethodLength")
@ParallelTest
public void testTemplate() {
- Map depLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map depAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map depLabels = TestUtils.modifiableMap("l1", "v1", "l2", "v2");
+ Map depAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = TestUtils.modifiableMap("l3", "v3", "l4", "v4");
+ Map podAnnotations = Map.of("a3", "v3", "a4", "v4");
- Map svcLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map svcAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map svcLabels = TestUtils.modifiableMap("l5", "v5", "l6", "v6");
+ Map svcAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map saLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map saAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map saLabels = Map.of("l7", "v7", "l8", "v8");
+ Map saAnnotations = Map.of("a7", "v7", "a8", "v8");
Affinity affinity = new AffinityBuilder()
.withNewNodeAffinity()
@@ -1183,7 +1183,7 @@ private CruiseControl createCruiseControl(Kafka kafka, Set nodes, Map expectedLabels(String name) {
- return TestUtils.map(Labels.STRIMZI_CLUSTER_LABEL, CLUSTER_NAME,
+ return TestUtils.modifiableMap(Labels.STRIMZI_CLUSTER_LABEL, CLUSTER_NAME,
"my-user-label", "cromulent",
Labels.STRIMZI_KIND_LABEL, Kafka.RESOURCE_KIND,
Labels.STRIMZI_NAME_LABEL, name,
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityOperatorTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityOperatorTest.java
index 643a323362a..ae46af98cca 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityOperatorTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityOperatorTest.java
@@ -206,21 +206,21 @@ public void withAffinityAndTolerations() throws IOException {
@ParallelTest
public void testTemplate() {
- Map depLabels = TestUtils.map("l1", "v1", "l2", "v2",
+ Map depLabels = Map.of("l1", "v1", "l2", "v2",
Labels.KUBERNETES_PART_OF_LABEL, "custom-part",
Labels.KUBERNETES_MANAGED_BY_LABEL, "custom-managed-by");
Map expectedDepLabels = new HashMap<>(depLabels);
expectedDepLabels.remove(Labels.KUBERNETES_MANAGED_BY_LABEL);
- Map depAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map depAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = Map.of("l3", "v3", "l4", "v4");
+ Map podAnnotations = Map.of("a3", "v3", "a4", "v4");
- Map saLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map saAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map saLabels = Map.of("l5", "v5", "l6", "v6");
+ Map saAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map rLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map rAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map rLabels = Map.of("l7", "v7", "l8", "v8");
+ Map rAnnotations = Map.of("a7", "v7", "a8", "v8");
Toleration toleration = new TolerationBuilder()
.withEffect("NoSchedule")
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityTopicOperatorTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityTopicOperatorTest.java
index 19b90370ed8..187d2685422 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityTopicOperatorTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityTopicOperatorTest.java
@@ -36,7 +36,6 @@
import static io.strimzi.operator.common.model.cruisecontrol.CruiseControlApiProperties.TOPIC_OPERATOR_PASSWORD_KEY;
import static io.strimzi.operator.common.model.cruisecontrol.CruiseControlApiProperties.TOPIC_OPERATOR_USERNAME;
import static io.strimzi.operator.common.model.cruisecontrol.CruiseControlApiProperties.TOPIC_OPERATOR_USERNAME_KEY;
-import static io.strimzi.test.TestUtils.map;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.notNullValue;
import static org.hamcrest.CoreMatchers.nullValue;
@@ -250,7 +249,7 @@ public void testGetContainers() {
assertThat(container.getPorts().get(0).getContainerPort(), is(EntityTopicOperator.HEALTHCHECK_PORT));
assertThat(container.getPorts().get(0).getName(), is(EntityTopicOperator.HEALTHCHECK_PORT_NAME));
assertThat(container.getPorts().get(0).getProtocol(), is("TCP"));
- assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(map(
+ assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(Map.of(
EntityTopicOperator.TOPIC_OPERATOR_TMP_DIRECTORY_DEFAULT_VOLUME_NAME, VolumeUtils.STRIMZI_TMP_DIRECTORY_DEFAULT_MOUNT_PATH,
"entity-topic-operator-metrics-and-logging", "/opt/topic-operator/custom-config/",
EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_NAME, EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_MOUNT,
@@ -318,7 +317,7 @@ public void testSetupWithCruiseControlEnabled() {
assertThat(entityTopicOperator.getEnvVars(), is(expectedEnvVars));
Container container = entityTopicOperator.createContainer(null);
- assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(map(
+ assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(Map.of(
EntityTopicOperator.TOPIC_OPERATOR_TMP_DIRECTORY_DEFAULT_VOLUME_NAME, VolumeUtils.STRIMZI_TMP_DIRECTORY_DEFAULT_MOUNT_PATH,
"entity-topic-operator-metrics-and-logging", "/opt/topic-operator/custom-config/",
EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_NAME, EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_MOUNT,
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityUserOperatorTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityUserOperatorTest.java
index 268645f7fc4..7ed948a9390 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityUserOperatorTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/EntityUserOperatorTest.java
@@ -34,7 +34,6 @@
import java.util.List;
import java.util.Map;
-import static io.strimzi.test.TestUtils.map;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.nullValue;
import static org.hamcrest.MatcherAssert.assertThat;
@@ -230,7 +229,7 @@ public void testGetContainers() {
assertThat(container.getPorts().get(0).getContainerPort(), is(EntityUserOperator.HEALTHCHECK_PORT));
assertThat(container.getPorts().get(0).getName(), is(EntityUserOperator.HEALTHCHECK_PORT_NAME));
assertThat(container.getPorts().get(0).getProtocol(), is("TCP"));
- assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(map(
+ assertThat(EntityOperatorTest.volumeMounts(container.getVolumeMounts()), is(Map.of(
EntityUserOperator.USER_OPERATOR_TMP_DIRECTORY_DEFAULT_VOLUME_NAME, VolumeUtils.STRIMZI_TMP_DIRECTORY_DEFAULT_MOUNT_PATH,
"entity-user-operator-metrics-and-logging", "/opt/user-operator/custom-config/",
EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_NAME, EntityOperator.TLS_SIDECAR_CA_CERTS_VOLUME_MOUNT,
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaBridgeClusterTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaBridgeClusterTest.java
index 258e2db3e14..8b0c0e29384 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaBridgeClusterTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaBridgeClusterTest.java
@@ -131,7 +131,7 @@ public class KafkaBridgeClusterTest {
private final KafkaBridgeCluster kbc = KafkaBridgeCluster.fromCrd(Reconciliation.DUMMY_RECONCILIATION, resource, SHARED_ENV_PROVIDER);
private Map expectedLabels(String name) {
- return TestUtils.map(Labels.STRIMZI_CLUSTER_LABEL, this.cluster,
+ return TestUtils.modifiableMap(Labels.STRIMZI_CLUSTER_LABEL, this.cluster,
"my-user-label", "cromulent",
Labels.STRIMZI_NAME_LABEL, name,
Labels.STRIMZI_COMPONENT_TYPE_LABEL, KafkaBridgeCluster.COMPONENT_TYPE,
@@ -425,24 +425,24 @@ public void testGenerateDeploymentWithPlainAuth() {
@ParallelTest
@SuppressWarnings({"checkstyle:methodlength"})
public void testTemplate() {
- Map depLabels = TestUtils.map("l1", "v1", "l2", "v2",
+ Map depLabels = Map.of("l1", "v1", "l2", "v2",
Labels.KUBERNETES_PART_OF_LABEL, "custom-part",
Labels.KUBERNETES_MANAGED_BY_LABEL, "custom-managed-by");
Map expectedDepLabels = new HashMap<>(depLabels);
expectedDepLabels.remove(Labels.KUBERNETES_MANAGED_BY_LABEL);
- Map depAnots = TestUtils.map("a1", "v1", "a2", "v2");
+ Map depAnots = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnots = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = Map.of("l3", "v3", "l4", "v4");
+ Map podAnots = Map.of("a3", "v3", "a4", "v4");
- Map svcLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map svcAnots = TestUtils.map("a5", "v5", "a6", "v6");
+ Map svcLabels = Map.of("l5", "v5", "l6", "v6");
+ Map svcAnots = Map.of("a5", "v5", "a6", "v6");
- Map pdbLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map pdbAnots = TestUtils.map("a7", "v7", "a8", "v8");
+ Map pdbLabels = Map.of("l7", "v7", "l8", "v8");
+ Map pdbAnots = Map.of("a7", "v7", "a8", "v8");
- Map saLabels = TestUtils.map("l9", "v9", "l10", "v10");
- Map saAnots = TestUtils.map("a9", "v9", "a10", "v10");
+ Map saLabels = Map.of("l9", "v9", "l10", "v10");
+ Map saAnots = Map.of("a9", "v9", "a10", "v10");
Affinity affinity = new AffinityBuilder()
.withNewNodeAffinity()
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterListenersTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterListenersTest.java
index 0b747f06790..c205c849d91 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterListenersTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterListenersTest.java
@@ -142,29 +142,29 @@ private Map expectedBrokerSelectorLabels() {
@SuppressWarnings({"checkstyle:MethodLength"})
@ParallelTest
public void testListenersTemplate() {
- Map svcLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map svcAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map svcLabels = Map.of("l5", "v5", "l6", "v6");
+ Map svcAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map hSvcLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map hSvcAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map hSvcLabels = Map.of("l7", "v7", "l8", "v8");
+ Map hSvcAnnotations = Map.of("a7", "v7", "a8", "v8");
- Map exSvcLabels = TestUtils.map("l9", "v9", "l10", "v10");
- Map exSvcAnnotations = TestUtils.map("a9", "v9", "a10", "v10");
+ Map exSvcLabels = Map.of("l9", "v9", "l10", "v10");
+ Map exSvcAnnotations = Map.of("a9", "v9", "a10", "v10");
- Map perPodSvcLabels = TestUtils.map("l11", "v11", "l12", "v12");
- Map perPodSvcAnnotations = TestUtils.map("a11", "v11", "a12", "v12");
+ Map perPodSvcLabels = Map.of("l11", "v11", "l12", "v12");
+ Map perPodSvcAnnotations = Map.of("a11", "v11", "a12", "v12");
- Map exRouteLabels = TestUtils.map("l13", "v13", "l14", "v14");
- Map exRouteAnnotations = TestUtils.map("a13", "v13", "a14", "v14");
+ Map exRouteLabels = Map.of("l13", "v13", "l14", "v14");
+ Map exRouteAnnotations = Map.of("a13", "v13", "a14", "v14");
- Map perPodRouteLabels = TestUtils.map("l15", "v15", "l16", "v16");
- Map perPodRouteAnnotations = TestUtils.map("a15", "v15", "a16", "v16");
+ Map perPodRouteLabels = Map.of("l15", "v15", "l16", "v16");
+ Map perPodRouteAnnotations = Map.of("a15", "v15", "a16", "v16");
- Map exIngressLabels = TestUtils.map("l17", "v17", "l18", "v18");
- Map exIngressAnnotations = TestUtils.map("a17", "v17", "a18", "v18");
+ Map exIngressLabels = Map.of("l17", "v17", "l18", "v18");
+ Map exIngressAnnotations = Map.of("a17", "v17", "a18", "v18");
- Map perPodIngressLabels = TestUtils.map("l19", "v19", "l20", "v20");
- Map perPodIngressAnnotations = TestUtils.map("a19", "v19", "a20", "v20");
+ Map perPodIngressLabels = Map.of("l19", "v19", "l20", "v20");
+ Map perPodIngressAnnotations = Map.of("a19", "v19", "a20", "v20");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
@@ -338,39 +338,39 @@ public void testListenersTemplate() {
@SuppressWarnings({"checkstyle:MethodLength"})
@ParallelTest
public void testListenersTemplateFromKafkaAndNodePools() {
- Map svcLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map svcAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map svcLabels = Map.of("l5", "v5", "l6", "v6");
+ Map svcAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map hSvcLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map hSvcAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map hSvcLabels = Map.of("l7", "v7", "l8", "v8");
+ Map hSvcAnnotations = Map.of("a7", "v7", "a8", "v8");
- Map exSvcLabels = TestUtils.map("l9", "v9", "l10", "v10");
- Map exSvcAnnotations = TestUtils.map("a9", "v9", "a10", "v10");
+ Map exSvcLabels = Map.of("l9", "v9", "l10", "v10");
+ Map exSvcAnnotations = Map.of("a9", "v9", "a10", "v10");
- Map perPodSvcLabels = TestUtils.map("l11", "v11", "l12", "v12");
- Map perPodSvcAnnotations = TestUtils.map("a11", "v11", "a12", "v12");
+ Map perPodSvcLabels = Map.of("l11", "v11", "l12", "v12");
+ Map perPodSvcAnnotations = Map.of("a11", "v11", "a12", "v12");
- Map exRouteLabels = TestUtils.map("l13", "v13", "l14", "v14");
- Map exRouteAnnotations = TestUtils.map("a13", "v13", "a14", "v14");
+ Map exRouteLabels = Map.of("l13", "v13", "l14", "v14");
+ Map exRouteAnnotations = Map.of("a13", "v13", "a14", "v14");
- Map perPodRouteLabels = TestUtils.map("l15", "v15", "l16", "v16");
- Map perPodRouteAnnotations = TestUtils.map("a15", "v15", "a16", "v16");
+ Map perPodRouteLabels = Map.of("l15", "v15", "l16", "v16");
+ Map perPodRouteAnnotations = Map.of("a15", "v15", "a16", "v16");
- Map exIngressLabels = TestUtils.map("l17", "v17", "l18", "v18");
- Map exIngressAnnotations = TestUtils.map("a17", "v17", "a18", "v18");
+ Map exIngressLabels = Map.of("l17", "v17", "l18", "v18");
+ Map exIngressAnnotations = Map.of("a17", "v17", "a18", "v18");
- Map perPodIngressLabels = TestUtils.map("l19", "v19", "l20", "v20");
- Map perPodIngressAnnotations = TestUtils.map("a19", "v19", "a20", "v20");
+ Map perPodIngressLabels = Map.of("l19", "v19", "l20", "v20");
+ Map perPodIngressAnnotations = Map.of("a19", "v19", "a20", "v20");
// Node pool values
- Map perPodSvcLabels2 = TestUtils.map("l21", "v21", "l22", "v22");
- Map perPodSvcAnnotations2 = TestUtils.map("a21", "v21", "a22", "v22");
+ Map perPodSvcLabels2 = Map.of("l21", "v21", "l22", "v22");
+ Map perPodSvcAnnotations2 = Map.of("a21", "v21", "a22", "v22");
- Map perPodRouteLabels2 = TestUtils.map("l25", "v25", "l26", "v26");
- Map perPodRouteAnnotations2 = TestUtils.map("a25", "v25", "a26", "v26");
+ Map perPodRouteLabels2 = Map.of("l25", "v25", "l26", "v26");
+ Map perPodRouteAnnotations2 = Map.of("a25", "v25", "a26", "v26");
- Map perPodIngressLabels2 = TestUtils.map("l29", "v29", "l30", "v30");
- Map perPodIngressAnnotations2 = TestUtils.map("a29", "v29", "a30", "v30");
+ Map perPodIngressLabels2 = Map.of("l29", "v29", "l30", "v30");
+ Map perPodIngressAnnotations2 = Map.of("a29", "v29", "a30", "v30");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
@@ -597,14 +597,14 @@ public void testListenersTemplateFromKafkaAndNodePools() {
@ParallelTest
public void testListenersTemplateFromNodePools() {
// Node pool values
- Map perPodSvcLabels2 = TestUtils.map("l21", "v21", "l22", "v22");
- Map perPodSvcAnnotations2 = TestUtils.map("a21", "v21", "a22", "v22");
+ Map perPodSvcLabels2 = Map.of("l21", "v21", "l22", "v22");
+ Map perPodSvcAnnotations2 = Map.of("a21", "v21", "a22", "v22");
- Map perPodRouteLabels2 = TestUtils.map("l25", "v25", "l26", "v26");
- Map perPodRouteAnnotations2 = TestUtils.map("a25", "v25", "a26", "v26");
+ Map perPodRouteLabels2 = Map.of("l25", "v25", "l26", "v26");
+ Map perPodRouteAnnotations2 = Map.of("a25", "v25", "a26", "v26");
- Map perPodIngressLabels2 = TestUtils.map("l29", "v29", "l30", "v30");
- Map perPodIngressAnnotations2 = TestUtils.map("a29", "v29", "a30", "v30");
+ Map perPodIngressLabels2 = Map.of("l29", "v29", "l30", "v30");
+ Map perPodIngressAnnotations2 = Map.of("a29", "v29", "a30", "v30");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterTest.java
index cfb153cd5fa..17344fbef82 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterTest.java
@@ -993,17 +993,17 @@ public void testContainerPorts() {
@ParallelTest
public void testAuxiliaryResourcesTemplate() {
- Map pdbLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map pdbAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map pdbLabels = Map.of("l1", "v1", "l2", "v2");
+ Map pdbAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map crbLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map crbAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map crbLabels = Map.of("l3", "v3", "l4", "v4");
+ Map crbAnnotations = Map.of("a3", "v3", "a4", "v4");
- Map saLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map saAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map saLabels = Map.of("l5", "v5", "l6", "v6");
+ Map saAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map jmxLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map jmxAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map jmxLabels = Map.of("l7", "v7", "l8", "v8");
+ Map jmxAnnotations = Map.of("a7", "v7", "a8", "v8");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
@@ -1889,8 +1889,8 @@ public void testDefaultPodDisruptionBudget() {
@ParallelTest
public void testCustomizedPodDisruptionBudget() {
- Map pdbLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map pdbAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map pdbLabels = Map.of("l1", "v1", "l2", "v2");
+ Map pdbAnnotations = Map.of("a1", "v1", "a2", "v2");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
@@ -3774,11 +3774,11 @@ public void testPodSet() {
@ParallelTest
public void testCustomizedPodSet() {
// Prepare various template values
- Map spsLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map spsAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map spsLabels = Map.of("l1", "v1", "l2", "v2");
+ Map spsAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = Map.of("l3", "v3", "l4", "v4");
+ Map podAnnotations = Map.of("a3", "v3", "a4", "v4");
HostAlias hostAlias1 = new HostAliasBuilder()
.withHostnames("my-host-1", "my-host-2")
@@ -4040,17 +4040,17 @@ public void testCustomizedPodSet() {
@ParallelTest
public void testCustomizedPodSetInKafkaAndNodePool() {
// Prepare various template values
- Map spsLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map spsAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map spsLabels = Map.of("l1", "v1", "l2", "v2");
+ Map spsAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = Map.of("l3", "v3", "l4", "v4");
+ Map podAnnotations = Map.of("a3", "v3", "a4", "v4");
- Map poolSpsLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map poolSpsAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map poolSpsLabels = Map.of("l5", "v5", "l6", "v6");
+ Map poolSpsAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map poolPodLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map poolPodAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map poolPodLabels = Map.of("l7", "v7", "l8", "v8");
+ Map poolPodAnnotations = Map.of("a7", "v7", "a8", "v8");
HostAlias hostAlias1 = new HostAliasBuilder()
.withHostnames("my-host-1", "my-host-2")
@@ -4435,11 +4435,11 @@ public void testCustomizedPodSetInKafkaAndNodePool() {
@ParallelTest
public void testCustomizedPodSetInNodePool() {
// Prepare various template values
- Map spsLabels = TestUtils.map("l1", "v1", "l2", "v2");
- Map spsAnnotations = TestUtils.map("a1", "v1", "a2", "v2");
+ Map spsLabels = Map.of("l1", "v1", "l2", "v2");
+ Map spsAnnotations = Map.of("a1", "v1", "a2", "v2");
- Map podLabels = TestUtils.map("l3", "v3", "l4", "v4");
- Map podAnnotations = TestUtils.map("a3", "v3", "a4", "v4");
+ Map podLabels = Map.of("l3", "v3", "l4", "v4");
+ Map podAnnotations = Map.of("a3", "v3", "a4", "v4");
HostAlias hostAlias1 = new HostAliasBuilder()
.withHostnames("my-host-1", "my-host-2")
diff --git a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterZooBasedTest.java b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterZooBasedTest.java
index c92b62d75f4..78e4083c535 100644
--- a/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterZooBasedTest.java
+++ b/cluster-operator/src/test/java/io/strimzi/operator/cluster/model/KafkaClusterZooBasedTest.java
@@ -124,7 +124,6 @@
import static io.strimzi.operator.cluster.model.jmx.JmxModel.JMX_PORT;
import static io.strimzi.operator.cluster.model.jmx.JmxModel.JMX_PORT_NAME;
-import static io.strimzi.test.TestUtils.set;
import static java.util.Arrays.asList;
import static java.util.Collections.emptyList;
import static java.util.Collections.emptyMap;
@@ -555,32 +554,32 @@ public void testExposesJmxContainerPortWhenJmxEnabled() {
@SuppressWarnings({"checkstyle:MethodLength"})
@ParallelTest
public void testTemplate() {
- Map svcLabels = TestUtils.map("l5", "v5", "l6", "v6");
- Map svcAnnotations = TestUtils.map("a5", "v5", "a6", "v6");
+ Map svcLabels = Map.of("l5", "v5", "l6", "v6");
+ Map svcAnnotations = Map.of("a5", "v5", "a6", "v6");
- Map hSvcLabels = TestUtils.map("l7", "v7", "l8", "v8");
- Map hSvcAnnotations = TestUtils.map("a7", "v7", "a8", "v8");
+ Map hSvcLabels = Map.of("l7", "v7", "l8", "v8");
+ Map hSvcAnnotations = Map.of("a7", "v7", "a8", "v8");
- Map exSvcLabels = TestUtils.map("l9", "v9", "l10", "v10");
- Map exSvcAnnotations = TestUtils.map("a9", "v9", "a10", "v10");
+ Map exSvcLabels = Map.of("l9", "v9", "l10", "v10");
+ Map exSvcAnnotations = Map.of("a9", "v9", "a10", "v10");
- Map perPodSvcLabels = TestUtils.map("l11", "v11", "l12", "v12");
- Map perPodSvcAnnotations = TestUtils.map("a11", "v11", "a12", "v12");
+ Map perPodSvcLabels = Map.of("l11", "v11", "l12", "v12");
+ Map perPodSvcAnnotations = Map.of("a11", "v11", "a12", "v12");
- Map exRouteLabels = TestUtils.map("l13", "v13", "l14", "v14");
- Map exRouteAnnotations = TestUtils.map("a13", "v13", "a14", "v14");
+ Map exRouteLabels = Map.of("l13", "v13", "l14", "v14");
+ Map exRouteAnnotations = Map.of("a13", "v13", "a14", "v14");
- Map perPodRouteLabels = TestUtils.map("l15", "v15", "l16", "v16");
- Map perPodRouteAnnotations = TestUtils.map("a15", "v15", "a16", "v16");
+ Map perPodRouteLabels = Map.of("l15", "v15", "l16", "v16");
+ Map perPodRouteAnnotations = Map.of("a15", "v15", "a16", "v16");
- Map pdbLabels = TestUtils.map("l17", "v17", "l18", "v18");
- Map pdbAnnotations = TestUtils.map("a17", "v17", "a18", "v18");
+ Map pdbLabels = Map.of("l17", "v17", "l18", "v18");
+ Map pdbAnnotations = Map.of("a17", "v17", "a18", "v18");
- Map crbLabels = TestUtils.map("l19", "v19", "l20", "v20");
- Map crbAnnotations = TestUtils.map("a19", "v19", "a20", "v20");
+ Map crbLabels = Map.of("l19", "v19", "l20", "v20");
+ Map crbAnnotations = Map.of("a19", "v19", "a20", "v20");
- Map saLabels = TestUtils.map("l21", "v21", "l22", "v22");
- Map saAnnotations = TestUtils.map("a21", "v21", "a22", "v22");
+ Map saLabels = Map.of("l21", "v21", "l22", "v22");
+ Map saAnnotations = Map.of("a21", "v21", "a22", "v22");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
@@ -1520,7 +1519,7 @@ public void testPvcsWithEmptyStorageSelector() {
@ParallelTest
public void testPvcsWithSetStorageSelector() {
- Map selector = TestUtils.map("foo", "bar");
+ Map selector = Map.of("foo", "bar");
Kafka kafkaAssembly = new KafkaBuilder(KAFKA)
.editSpec()
.editKafka()
@@ -2401,13 +2400,13 @@ public void testGetExternalNodePortServiceAddressOverrideWithNonNullAdvertisedHo
@ParallelTest
public void testGenerateBrokerSecret() throws CertificateParsingException {
Secret secret = generateBrokerSecret(null, emptyMap());
- assertThat(secret.getData().keySet(), is(set(
+ assertThat(secret.getData().keySet(), is(Set.of(
"foo-kafka-0.crt", "foo-kafka-0.key",
"foo-kafka-1.crt", "foo-kafka-1.key",
"foo-kafka-2.crt", "foo-kafka-2.key")));
X509Certificate cert = Ca.cert(secret, "foo-kafka-0.crt");
assertThat(cert.getSubjectX500Principal().getName(), is("CN=foo-kafka,O=io.strimzi"));
- assertThat(new HashSet