remove static so running multiple crossClusterOperations using AVRO d…

…oesn't cause problems
patschuh · Mar 22, 2019 · b2dd46e · b2dd46e
1 parent 7e4c561
commit b2dd46e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/at/esque/kafka/serialization/KafkaEsqueDeserializer.java b/src/main/java/at/esque/kafka/serialization/KafkaEsqueDeserializer.java
@@ -11,8 +11,8 @@
 
 public class KafkaEsqueDeserializer implements Deserializer<Object> {
 
-    private static ForgivingKafkaAvroDeserializer avroDeserializer;
-    private static StringDeserializer stringDeserializer;
+    private ForgivingKafkaAvroDeserializer avroDeserializer;
+    private StringDeserializer stringDeserializer;
 
     public KafkaEsqueDeserializer() {
         avroDeserializer = new ForgivingKafkaAvroDeserializer();