From 1bfe392b53a3ea4d2f1bd63e1492e345b8315681 Mon Sep 17 00:00:00 2001
From: Ramin Gharib <ramin.gharib@bakdata.com>
Date: Tue, 25 Jun 2024 09:44:57 +0200
Subject: [PATCH] Update files

---
 .../src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java
index 61f6e13d..7246d138 100644
--- a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java
+++ b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java
@@ -99,7 +99,7 @@ public static void runResetter(final Collection<String> inputTopics, final Colle
             final Collection<String> allTopics, final ImprovedStreamsConfig streamsAppConfig) {
         // StreamsResetter's internal AdminClient can only be configured with a properties file
         final String appId = streamsAppConfig.getAppId();
-        final File tempFile = createTemporaryPropertiesFile(appId, streamsAppConfig.getStreamsConfig());
+        final File tempFile = createTemporaryPropertiesFile(appId, streamsAppConfig.getKafkaProperties());
         final ImmutableList.Builder<String> argList = ImmutableList.<String>builder()
                 .add("--application-id", appId)
                 .add("--bootstrap-server", streamsAppConfig.getBoostrapServers())
@@ -183,7 +183,7 @@ public void reset() {
     }
 
     private Map<String, Object> getKafkaProperties() {
-        return this.config.getStreamsConfig();
+        return this.config.getKafkaProperties();
     }
 
     private ImprovedAdminClient createAdminClient() {