Upgrade to Kafka 3.8

bakdata · Jan 7, 2025 · f4b9e73 · f4b9e73
1 parent e218f30
commit f4b9e73
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/streams-bootstrap-large-messages/src/main/java/com/bakdata/kafka/LargeMessageAppUtils.java b/streams-bootstrap-large-messages/src/main/java/com/bakdata/kafka/LargeMessageAppUtils.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2024 bakdata
+ * Copyright (c) 2025 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -77,12 +77,16 @@ public static <T> T registerTopicHook(
 
     @RequiredArgsConstructor
     private static class LargeMessageTopicHook implements TopicHook {
-        //TODO: close storer once it implements AutoCloseable
         private final @NonNull LargeMessageStoringClient storer;
 
         @Override
         public void deleted(final String topic) {
             this.storer.deleteAllFiles(topic);
         }
+
+        @Override
+        public void close() {
+            this.storer.close();
+        }
     }
 }