From 6d216575e1710ca3eddae6098ddefa3b16925a38 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Fri, 5 Apr 2024 11:41:11 +0200
Subject: [PATCH] Create v3

---
 .../com/bakdata/kafka/integration/RunProducerAppTest.java | 6 +++---
 .../java/com/bakdata/kafka/ConfiguredProducerAppTest.java | 8 ++++----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java b/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
index babba1b8..77186ef1 100644
--- a/streams-bootstrap-picocli/src/test/java/com/bakdata/kafka/integration/RunProducerAppTest.java
+++ b/streams-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
index 488f31dd..473e1b9c 100644
--- 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"
+            );
         }
     }
 }