diff --git a/kroxylicious-filter/src/main/java/io/strimzi/kafka/topicenc/kroxylicious/TopicEncryptionConfig.java b/kroxylicious-filter/src/main/java/io/strimzi/kafka/topicenc/kroxylicious/TopicEncryptionConfig.java index 47ad298..85a8be7 100644 --- a/kroxylicious-filter/src/main/java/io/strimzi/kafka/topicenc/kroxylicious/TopicEncryptionConfig.java +++ b/kroxylicious-filter/src/main/java/io/strimzi/kafka/topicenc/kroxylicious/TopicEncryptionConfig.java @@ -1,16 +1,11 @@ package io.strimzi.kafka.topicenc.kroxylicious; -import java.time.Duration; import java.util.Objects; import java.util.concurrent.ConcurrentHashMap; -import org.apache.kafka.common.Uuid; - import com.fasterxml.jackson.annotation.JsonCreator; import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonProperty; -import com.github.benmanes.caffeine.cache.AsyncLoadingCache; -import com.github.benmanes.caffeine.cache.Caffeine; import io.strimzi.kafka.topicenc.policy.PolicyRepository; @@ -23,7 +18,6 @@ public class TopicEncryptionConfig extends BaseConfig { @JsonIgnore private static final ConcurrentHashMap virtualClusterToTopicUUIDToTopicNameCache = new ConcurrentHashMap<>(); - private final ContextCacheLoader contextCacheLoader = new ContextCacheLoader(); @JsonCreator public TopicEncryptionConfig(@JsonProperty(value = IN_MEMORY_POLICY_REPOSITORY_PROP_NAME) InMemoryPolicyRepositoryConfig inMemoryPolicyRepository) { @@ -32,10 +26,6 @@ public TopicEncryptionConfig(@JsonProperty(value = IN_MEMORY_POLICY_REPOSITORY_P + " configuration is required as it is the only PolicyRepository implementation"); } - public ContextCacheLoader getContextCacheLoader() { - return contextCacheLoader; - } - public PolicyRepository getPolicyRepository() { return inMemoryPolicyRepository.getPolicyRepository(); }