Create v3

bakdata · Apr 4, 2024 · 706141e · 706141e
1 parent a3e30a1
commit 706141e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...rap-large-messages/src/main/java/com/bakdata/kafka/LargeMessageKafkaApplicationUtils.java b/...rap-large-messages/src/main/java/com/bakdata/kafka/LargeMessageKafkaApplicationUtils.java
@@ -45,7 +45,12 @@ public class LargeMessageKafkaApplicationUtils {
     public static TopicHook createLargeMessageCleanUpHook(final Map<String, Object> kafkaProperties) {
         final AbstractLargeMessageConfig largeMessageConfig = new AbstractLargeMessageConfig(kafkaProperties);
         final LargeMessageStoringClient storer = largeMessageConfig.getStorer();
-        return storer::deleteAllFiles;
+        return new TopicHook() {
+            @Override
+            public void deleted(final String topic) {
+                storer.deleteAllFiles(topic);
+            }
+        };
     }
 
     /**