Create v3

bakdata · Apr 5, 2024 · 6d21657 · 6d21657
1 parent 990bd4c
commit 6d21657
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...ams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java b/...ams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
@@ -80,9 +80,9 @@ public void run(final ProducerBuilder builder) {
 
             @Override
             public Map<String, Object> createKafkaProperties() {
-                final Map<String, Object> kafkaProperties = ProducerApp.super.createKafkaProperties();
-                kafkaProperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
-                return kafkaProperties;
+                return Map.of(
+                        ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class
+                );
             }
         })) {
             app.setBrokers(this.kafkaCluster.getBrokerList());

diff --git a/streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java b/streams-bootstrap/src/test/java/com/bakdata/kafka/ConfiguredProducerAppTest.java
@@ -86,10 +86,10 @@ public void run(final ProducerBuilder builder) {
 
         @Override
         public Map<String, Object> createKafkaProperties() {
-            final Map<String, Object> properties = ProducerApp.super.createKafkaProperties();
-            properties.put("foo", "bar");
-            properties.put("hello", "world");
-            return properties;
+            return Map.of(
+                    "foo", "bar",
+                    "hello", "world"
+            );
         }
     }
 }