From c180f450626d1b84aad2fa67b4cf8d1a0c8ce48c Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Wed, 6 Dec 2023 17:06:26 -0800 Subject: [PATCH] Fix findbugs --- .../schemaregistry/encryption/FieldEncryptionExecutor.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/client-encryption/src/main/java/io/confluent/kafka/schemaregistry/encryption/FieldEncryptionExecutor.java b/client-encryption/src/main/java/io/confluent/kafka/schemaregistry/encryption/FieldEncryptionExecutor.java index bed8d036f1f..edf56f3c5b5 100644 --- a/client-encryption/src/main/java/io/confluent/kafka/schemaregistry/encryption/FieldEncryptionExecutor.java +++ b/client-encryption/src/main/java/io/confluent/kafka/schemaregistry/encryption/FieldEncryptionExecutor.java @@ -16,7 +16,6 @@ package io.confluent.kafka.schemaregistry.encryption; -import com.google.common.base.Ticker; import com.google.crypto.tink.Aead; import com.google.crypto.tink.KmsClient; import com.google.crypto.tink.proto.AesGcmKey; @@ -87,7 +86,6 @@ public class FieldEncryptionExecutor extends FieldRuleExecutor { private Map configs; private int cacheExpirySecs = -1; private int cacheSize = 10000; - private Ticker ticker = Ticker.systemTicker(); private DekRegistryClient client; public FieldEncryptionExecutor() { @@ -118,10 +116,6 @@ public void configure(Map configs) { throw new ConfigException("Cannot parse " + CACHE_SIZE); } } - Object ticker = configs.get(TICKER); - if (ticker instanceof Ticker) { - this.ticker = (Ticker) ticker; - } Object url = configs.get(AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG); if (url == null) { throw new ConfigException("Missing schema registry url!");