Skip to content

Commit

Permalink
Fix findbugs
Browse files Browse the repository at this point in the history
  • Loading branch information
rayokota committed Dec 7, 2023
1 parent 92a148c commit c180f45
Showing 1 changed file with 0 additions and 6 deletions.
Expand Up @@ -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;
Expand Down Expand Up @@ -87,7 +86,6 @@ public class FieldEncryptionExecutor extends FieldRuleExecutor {
private Map<String, ?> configs;
private int cacheExpirySecs = -1;
private int cacheSize = 10000;
private Ticker ticker = Ticker.systemTicker();
private DekRegistryClient client;

public FieldEncryptionExecutor() {
Expand Down Expand Up @@ -118,10 +116,6 @@ public void configure(Map<String, ?> 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!");
Expand Down

0 comments on commit c180f45

Please sign in to comment.