diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/ConcurrentHashMapCache.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/ConcurrentHashMapCache.java
deleted file mode 100644
index 76dc615fcb..0000000000
--- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/ConcurrentHashMapCache.java
+++ /dev/null
@@ -1,38 +0,0 @@
-package io.javaoperatorsdk.operator.processing.event.source;
-
-import java.util.Map;
-import java.util.Optional;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.function.Predicate;
-import java.util.stream.Stream;
-
-import io.javaoperatorsdk.operator.processing.event.ResourceID;
-
-public class ConcurrentHashMapCache<T> implements UpdatableCache<T> {
-  private final Map<ResourceID, T> cache = new ConcurrentHashMap<>();
-
-  @Override
-  public Optional<T> get(ResourceID resourceID) {
-    return Optional.ofNullable(cache.get(resourceID));
-  }
-
-  @Override
-  public Stream<ResourceID> keys() {
-    return cache.keySet().stream();
-  }
-
-  @Override
-  public Stream<T> list(Predicate<T> predicate) {
-    return cache.values().stream().filter(predicate);
-  }
-
-  @Override
-  public T remove(ResourceID key) {
-    return cache.remove(key);
-  }
-
-  @Override
-  public void put(ResourceID key, T resource) {
-    cache.put(key, resource);
-  }
-}