Change CacheUpdateHandler to extend Configurable

rayokota · Aug 20, 2023 · c8aa883 · c8aa883
1 parent d966239
commit c8aa883
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/kcache/src/main/java/io/kcache/CacheUpdateHandler.java b/kcache/src/main/java/io/kcache/CacheUpdateHandler.java
@@ -18,21 +18,28 @@
 
 import java.util.Map;
 import java.util.Optional;
+import org.apache.kafka.common.Configurable;
 import org.apache.kafka.common.TopicPartition;
 
 import java.io.Closeable;
 import java.io.IOException;
 import org.apache.kafka.common.header.Headers;
 import org.apache.kafka.common.record.TimestampType;
 
-public interface CacheUpdateHandler<K, V> extends Closeable {
+public interface CacheUpdateHandler<K, V> extends Configurable, Closeable {
 
  enum ValidationStatus {
  SUCCESS,
  ROLLBACK_FAILURE,
  IGNORE_FAILURE
  }
 
+ /**
+ * Configures the cache update handler.
+ */
+ default void configure(Map<String, ?> configs) {
+ }
+
  /**
  * Invoked after the cache is initialized.
  *