From 4fb430279f95da154e12dfd0eccd21aa1c173680 Mon Sep 17 00:00:00 2001
From: Philipp Schirmer <philipp.schirmer@bakdata.com>
Date: Tue, 20 Aug 2024 13:07:24 +0200
Subject: [PATCH] Upgrade to streams-bootstrap v3

---
 .../kafka/DeadLetterAnalyzerTopologyTest.java | 27 ++++++++++---------
 1 file changed, 14 insertions(+), 13 deletions(-)

diff --git a/src/test/java/com/bakdata/kafka/DeadLetterAnalyzerTopologyTest.java b/src/test/java/com/bakdata/kafka/DeadLetterAnalyzerTopologyTest.java
index 5411c31..a594610 100644
--- a/src/test/java/com/bakdata/kafka/DeadLetterAnalyzerTopologyTest.java
+++ b/src/test/java/com/bakdata/kafka/DeadLetterAnalyzerTopologyTest.java
@@ -569,19 +569,20 @@ private void assertNoDeadLetters() {
     }
 
     private TestTopologyExtension<String, DeadLetter> createTestTopology() {
-        final ConfiguredStreamsApp<DeadLetterAnalyzerApplication> configuredApp =
-                new ConfiguredStreamsApp<>(new DeadLetterAnalyzerApplication(),
-                        new AppConfiguration<>(StreamsTopicConfig.builder()
-                                .inputPattern(Pattern.compile(".*-dead-letter-topic"))
-                                .outputTopic("output")
-                                .errorTopic("analyzer-stream-dead-letter-topic")
-                                .labeledOutputTopics(
-                                        Map.of(
-                                                EXAMPLES_TOPIC_LABEL, "examples",
-                                                STATS_TOPIC_LABEL, "stats"
-                                        )
-                                )
-                                .build()));
+        final StreamsApp app = new DeadLetterAnalyzerApplication();
+        final StreamsTopicConfig topicConfig = StreamsTopicConfig.builder()
+                .inputPattern(Pattern.compile(".*-dead-letter-topic"))
+                .outputTopic("output")
+                .errorTopic("analyzer-stream-dead-letter-topic")
+                .labeledOutputTopics(
+                        Map.of(
+                                EXAMPLES_TOPIC_LABEL, "examples",
+                                STATS_TOPIC_LABEL, "stats"
+                        )
+                )
+                .build();
+        final ConfiguredStreamsApp<StreamsApp> configuredApp =
+                new ConfiguredStreamsApp<>(app, new AppConfiguration<>(topicConfig));
         return new TestTopologyExtension<>(properties -> this.createTopology(properties, configuredApp),
                 TestTopologyFactory.getKafkaPropertiesWithSchemaRegistryUrl(configuredApp));
     }