diff --git a/kcache/src/main/java/io/kcache/KafkaCache.java b/kcache/src/main/java/io/kcache/KafkaCache.java index a1c5f2cd..11b593dd 100644 --- a/kcache/src/main/java/io/kcache/KafkaCache.java +++ b/kcache/src/main/java/io/kcache/KafkaCache.java @@ -22,12 +22,8 @@ import io.kcache.exceptions.CacheTimeoutException; import io.kcache.utils.InMemoryBoundedCache; import io.kcache.utils.InMemoryCache; -import io.kcache.utils.PersistentCache; -import io.kcache.utils.ShutdownableThread; import io.kcache.utils.OffsetCheckpoint; -import java.lang.reflect.Constructor; -import java.util.Locale; -import java.util.Objects; +import io.kcache.utils.ShutdownableThread; import org.apache.kafka.clients.admin.AdminClient; import org.apache.kafka.clients.admin.AdminClientConfig; import org.apache.kafka.clients.admin.Config; @@ -61,13 +57,16 @@ import org.slf4j.LoggerFactory; import java.io.IOException; +import java.lang.reflect.Constructor; import java.time.Duration; import java.util.Collection; import java.util.Collections; import java.util.Comparator; import java.util.HashMap; import java.util.List; +import java.util.Locale; import java.util.Map; +import java.util.Objects; import java.util.Properties; import java.util.Set; import java.util.concurrent.ConcurrentHashMap;