Upgrade to streams-bootstrap v3

bakdata · Aug 20, 2024 · 4fb4302 · 4fb4302
1 parent a37534b
commit 4fb4302
Showing 1 changed file with 14 additions and 13 deletions.
diff --git 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));
     }