remove unused fields and method
@@ -15,12 +15,9 @@ public class SecorSchemaRegistryClient {
private static final Logger LOG = LoggerFactory.getLogger(SecorSchemaRegistryClient.class);
- private static Object mutex = new Object();
private KafkaAvroDecoder decoder;
private static Map<String, Schema> schemas;
- private static volatile SecorSchemaRegistryClient instance = null;
-
public SecorSchemaRegistryClient(SecorConfig config) {
try {
LOG.info("Initializing schema registry {}", config.getSchemaRegistryUrl());
@@ -50,10 +47,4 @@ public class SecorSchemaRegistryClient {
}
}
- // public static GenericRecord decodeMessage(Message message) {
-// GenericRecord record = (GenericRecord) decoder.fromBytes(message.getPayload());
-// schemas.put(message.getTopic(), record.getSchema());
-// return record;
-// }
-
}
