diff --git a/src/main/java/com/bakdata/common_kafka_streams/KafkaStreamsApplication.java b/src/main/java/com/bakdata/common_kafka_streams/KafkaStreamsApplication.java
index f0fb3920e..27e52eb4e 100644
--- a/src/main/java/com/bakdata/common_kafka_streams/KafkaStreamsApplication.java
+++ b/src/main/java/com/bakdata/common_kafka_streams/KafkaStreamsApplication.java
@@ -201,7 +201,7 @@ public Properties getKafkaProperties() {
         return kafkaConfig;
     }
 
-    private static void runResetter(final String inputTopics, final String brokers, final String appId) {
+    protected static void runResetter(final String inputTopics, final String brokers, final String appId) {
         final String[] args = {
                 "--application-id", appId,
                 "--bootstrap-servers", brokers,