diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArrayDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArrayDeserializer.cs
index 33912650f8..6725220857 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArrayDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArrayDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ByteArrayDeserializer : Deserializer<byte[]>
+    public class ByteArrayDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ByteArrayDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ByteArrayDeserializer";
 
-        public override bool AutoInit => false;
+        public byte[] Deserialize(string topic, byte[] data) => IExecute<byte[]>("deserialize", topic, data);
 
-        public ByteArrayDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Deserialize(string topic, byte[] data) => IExecute<byte[]>("deserialize", topic, data);
+        public static implicit operator Deserializer<byte[]>(ByteArrayDeserializer t) => t.CastTo<Deserializer<byte[]>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArraySerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArraySerializer.cs
index 65862f2937..8567c57176 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArraySerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteArraySerializer.cs
@@ -18,18 +18,11 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ByteArraySerializer : Serializer<byte[]>
+    public class ByteArraySerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ByteArraySerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ByteArraySerializer";
+        public byte[] Serialize(string topic, byte[] data) => IExecute<byte[]>("serialize", topic, data);
 
-        public override bool AutoInit => false;
-
-        public ByteArraySerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, byte[] data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<byte[]>(ByteArraySerializer t) => t.CastTo<Serializer<byte[]>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferDeserializer.cs
index 92b235857c..52aa8ea9eb 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferDeserializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ByteBufferDeserializer : Deserializer<ByteBuffer>
+    public class ByteBufferDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ByteBufferDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ByteBufferDeserializer";
 
-        public override bool AutoInit => false;
+        public ByteBuffer Deserialize(string topic, byte[] data) => IExecute<ByteBuffer>("deserialize", topic, data);
 
-        public ByteBufferDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override ByteBuffer Deserialize(string topic, byte[] data) => IExecute<ByteBuffer>("deserialize", topic, data);
+        public static implicit operator Deserializer<ByteBuffer>(ByteBufferDeserializer t) => t.CastTo<Deserializer<ByteBuffer>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferSerializer.cs
index d7ea8fe37a..d95b9a7016 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ByteBufferSerializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ByteBufferSerializer : Serializer<ByteBuffer>
+    public class ByteBufferSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ByteBufferSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ByteBufferSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, ByteBuffer data) => IExecute<byte[]>("serialize", topic, data);
 
-        public ByteBufferSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, ByteBuffer data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<ByteBuffer>(ByteBufferSerializer t) => t.CastTo<Serializer<ByteBuffer>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesDeserializer.cs
index 52e04149f6..3cbe547aee 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesDeserializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class BytesDeserializer : Deserializer<Bytes>
+    public class BytesDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<BytesDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.BytesDeserializer";
 
-        public override bool AutoInit => false;
+        public Bytes Deserialize(string topic, byte[] data) => IExecute<Bytes>("deserialize", topic, data);
 
-        public BytesDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override Bytes Deserialize(string topic, byte[] data) => IExecute<Bytes>("deserialize", topic, data);
+        public static implicit operator Deserializer<Bytes>(BytesDeserializer t) => t.CastTo<Deserializer<Bytes>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesSerializer.cs
index 21c89c86a2..bf87ede764 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/BytesSerializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class BytesSerializer : Serializer<Bytes>
+    public class BytesSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<BytesSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.BytesSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, Bytes data) => IExecute<byte[]>("serialize", topic, data);
 
-        public BytesSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, Bytes data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<Bytes>(BytesSerializer t) => t.CastTo<Serializer<Bytes>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Deserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Deserializer.cs
index fe327d897f..928952330f 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Deserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Deserializer.cs
@@ -73,6 +73,13 @@ public class Deserializer<E> : JVMBridgeListener, IDeserializer<E>
         /// The <see cref="Func{String, Headers, Byte[], E}"/> to be executed on deserialize
         /// </summary>
         public virtual Func<string, Headers, byte[], E> OnDeserializeWithHeaders { get { return deserializeWithHeaders; } }
+        /// <summary>
+        /// Default constructor
+        /// </summary>
+        public Deserializer()
+        {
+        }
+
         /// <summary>
         /// Initialize a new instance of <see cref="Deserializer{E}"/>
         /// </summary>
@@ -91,7 +98,6 @@ public Deserializer(Func<string, byte[], E> deserializeFun = null, Func<string,
                 AddEventHandler("deserializeWithHeaders", new EventHandler<CLRListenerEventArgs<CLREventData<string>>>(EventHandlerWithHeaders));
             }
         }
-
         void EventHandler(object sender, CLRListenerEventArgs<CLREventData<string>> data)
         {
             var container = data.EventData.ExtraData.Get(0) as IJavaObject; // it is a byte[]
@@ -100,7 +106,6 @@ void EventHandler(object sender, CLRListenerEventArgs<CLREventData<string>> data
             var retVal = OnDeserialize(data.EventData.TypedEventData, bytes);
             data.SetReturnValue(retVal);
         }
-
         void EventHandlerWithHeaders(object sender, CLRListenerEventArgs<CLREventData<string>> data)
         {
             var headers = data.EventData.ExtraData.Get(0) as IJavaObject; // it is a Headers
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleDeserializer.cs
index deaf871f3e..204452ad28 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class DoubleDeserializer : Deserializer<double>
+    public class DoubleDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<DoubleDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.DoubleDeserializer";
 
-        public override bool AutoInit => false;
+        public double Deserialize(string topic, byte[] data) => IExecute<double>("deserialize", topic, data);
 
-        public DoubleDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override double Deserialize(string topic, byte[] data) => IExecute<double>("deserialize", topic, data);
+        public static implicit operator Deserializer<double>(DoubleDeserializer t) => t.CastTo<Deserializer<double>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleSerializer.cs
index b4eff631a8..16c8789351 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/DoubleSerializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class DoubleSerializer : Serializer<double>
+    public class DoubleSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<DoubleSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.DoubleSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, double data) => IExecute<byte[]>("serialize", topic, data);
 
-        public DoubleSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, double data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<double>(DoubleSerializer t) => t.CastTo<Serializer<double>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatDeserializer.cs
index 77ebf4251e..bd0a1b57a6 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class FloatDeserializer : Deserializer<float>
+    public class FloatDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<FloatDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.FloatDeserializer";
 
-        public override bool AutoInit => false;
+        public float Deserialize(string topic, byte[] data) => IExecute<float>("deserialize", topic, data);
 
-        public FloatDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override float Deserialize(string topic, byte[] data) => IExecute<float>("deserialize", topic, data);
+        public static implicit operator Deserializer<float>(FloatDeserializer t) => t.CastTo<Deserializer<float>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatSerializer.cs
index 2378fe9a7c..777204476a 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/FloatSerializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class FloatSerializer : Serializer<float>
+    public class FloatSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<FloatSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.FloatSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, float data) => IExecute<byte[]>("serialize", topic, data);
 
-        public FloatSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, float data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<float>(FloatSerializer t) => t.CastTo<Serializer<float>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerDeserializer.cs
index 0d7c7b779c..1eff090dfb 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class IntegerDeserializer : Deserializer<int>
+    public class IntegerDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<IntegerDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.IntegerDeserializer";
 
-        public override bool AutoInit => false;
+        public int Deserialize(string topic, byte[] data) => IExecute<int>("deserialize", topic, data);
 
-        public IntegerDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override int Deserialize(string topic, byte[] data) => IExecute<int>("deserialize", topic, data);
+        public static implicit operator Deserializer<int>(IntegerDeserializer t) => t.CastTo<Deserializer<int>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerSerializer.cs
index aefc69365c..226d0e3858 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/IntegerSerializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class IntegerSerializer : Serializer<int>
+    public class IntegerSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<IntegerSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.IntegerSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, int data) => IExecute<byte[]>("serialize", topic, data);
 
-        public IntegerSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, int data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<int>(IntegerSerializer t) => t.CastTo<Serializer<int>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListDeserializer.cs
index 22295600de..be5144d4f0 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListDeserializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ListDeserializer<Inner> : Deserializer<List<Inner>>
+    public class ListDeserializer<Inner> : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ListDeserializer<Inner>>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ListDeserializer";
 
-        public override bool AutoInit => false;
+        public List<Inner> Deserialize(string topic, byte[] data) => IExecute<List<Inner>>("deserialize", topic, data);
 
-        public ListDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override List<Inner> Deserialize(string topic, byte[] data) => IExecute<List<Inner>>("deserialize", topic, data);
+        public static implicit operator Deserializer<List<Inner>>(ListDeserializer<Inner> t) => t.CastTo<Deserializer<List<Inner>>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListSerializer.cs
index 33227d29f2..a06abf5d42 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ListSerializer.cs
@@ -16,23 +16,16 @@
 *  Refer to LICENSE for more information.
 */
 
-using Java.Nio;
 using Java.Util;
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ListSerializer<Inner> : Serializer<List<Inner>>
+    public class ListSerializer<Inner> : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ListSerializer<Inner>>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ListSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, List<Inner> data) => IExecute<byte[]>("serialize", topic, data);
 
-        public ListSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, List<Inner> data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<List<Inner>>(ListSerializer<Inner> t) => t.CastTo<Serializer<List<Inner>>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongDeserializer.cs
index 2b101163fc..e4ca399f88 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class LongDeserializer : Deserializer<long>
+    public class LongDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<LongDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.LongDeserializer";
 
-        public override bool AutoInit => false;
+        public long Deserialize(string topic, byte[] data) => IExecute<long>("deserialize", topic, data);
 
-        public LongDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override long Deserialize(string topic, byte[] data) => IExecute<long>("deserialize", topic, data);
+        public static implicit operator Deserializer<long>(LongDeserializer t) => t.CastTo<Deserializer<long>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongSerializer.cs
index 66712407a1..e05059f5eb 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/LongSerializer.cs
@@ -16,22 +16,14 @@
 *  Refer to LICENSE for more information.
 */
 
-using Java.Nio;
-
 namespace MASES.KNet.Common.Serialization
 {
-    public class LongSerializer : Serializer<long>
+    public class LongSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<LongSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.LongSerializer";
 
-        public override bool AutoInit => false;
-
-        public LongSerializer()
-            : base(null, null, false)
-        {
-
-        }
+        public byte[] Serialize(string topic, long data) => IExecute<byte[]>("serialize", topic, data);
 
-        public override byte[] Serialize(string topic, long data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<long>(LongSerializer t) => t.CastTo<Serializer<long>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Serializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Serializer.cs
index 3524f44a50..7f122d7b5f 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Serializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/Serializer.cs
@@ -73,6 +73,14 @@ public class Serializer<E> : JVMBridgeListener, ISerializer<E>
         /// The <see cref="Func{String, Headers, E, Byte[]}"/> to be executed on serialize
         /// </summary>
         public virtual Func<string, Headers, E, byte[]> OnSerializeWithHeaders { get { return serializeWithHeaders; } }
+
+        /// <summary>
+        /// Default constructor
+        /// </summary>
+        public Serializer()
+        {
+        }
+
         /// <summary>
         /// Initialize a new instance of <see cref="Serializer{E}"/>
         /// </summary>
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortDeserializer.cs
index 3c6d4f4803..0220aa6bb1 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class ShortDeserializer : Deserializer<short>
+    public class ShortDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ShortDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ShortDeserializer";
 
-        public override bool AutoInit => false;
+        public short Deserialize(string topic, byte[] data) => IExecute<short>("deserialize", topic, data);
 
-        public ShortDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override short Deserialize(string topic, byte[] data) => IExecute<short>("deserialize", topic, data);
+        public static implicit operator Deserializer<short>(ShortDeserializer t) => t.CastTo<Deserializer<short>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortSerializer.cs
index b82aae6f1b..d70b6e9db2 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/ShortSerializer.cs
@@ -16,22 +16,14 @@
 *  Refer to LICENSE for more information.
 */
 
-using Java.Nio;
-
 namespace MASES.KNet.Common.Serialization
 {
-    public class ShortSerializer : Serializer<short>
+    public class ShortSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<ShortSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.ShortSerializer";
 
-        public override bool AutoInit => false;
-
-        public ShortSerializer()
-            : base(null, null, false)
-        {
-
-        }
+        public byte[] Serialize(string topic, short data) => IExecute<byte[]>("serialize", topic, data);
 
-        public override byte[] Serialize(string topic, short data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<short>(ShortSerializer t) => t.CastTo<Serializer<short>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringDeserializer.cs
index f99de29224..4263e736b7 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class StringDeserializer : Deserializer<string>
+    public class StringDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<StringDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.StringDeserializer";
 
-        public override bool AutoInit => false;
+        public string Deserialize(string topic, byte[] data) => IExecute<string>("deserialize", topic, data);
 
-        public StringDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override string Deserialize(string topic, byte[] data) => IExecute<string>("deserialize", topic, data);
+        public static implicit operator Deserializer<string>(StringDeserializer t) => t.CastTo<Deserializer<string>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringSerializer.cs
index 10aba18dad..2bcdb93ea3 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/StringSerializer.cs
@@ -16,22 +16,14 @@
 *  Refer to LICENSE for more information.
 */
 
-using Java.Nio;
-
 namespace MASES.KNet.Common.Serialization
 {
-    public class StringSerializer : Serializer<string>
+    public class StringSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<StringSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.StringSerializer";
 
-        public override bool AutoInit => false;
-
-        public StringSerializer()
-            : base(null, null, false)
-        {
-
-        }
+        public byte[] Serialize(string topic, string data) => IExecute<byte[]>("serialize", topic, data);
 
-        public override byte[] Serialize(string topic, string data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<string>(StringSerializer t) => t.CastTo<Serializer<string>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDDeserializer.cs
index f946857c04..5177820419 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDDeserializer.cs
@@ -18,18 +18,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class UUIDDeserializer : Deserializer<Uuid>
+    public class UUIDDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<UUIDDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.UUIDDeserializer";
 
-        public override bool AutoInit => false;
+        public Uuid Deserialize(string topic, byte[] data) => IExecute<Uuid>("deserialize", topic, data);
 
-        public UUIDDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override Uuid Deserialize(string topic, byte[] data) => IExecute<Uuid>("deserialize", topic, data);
+        public static implicit operator Deserializer<Uuid>(UUIDDeserializer t) => t.CastTo<Deserializer<Uuid>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDSerializer.cs
index 6be952d1fd..bc10b9eded 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/UUIDSerializer.cs
@@ -16,22 +16,14 @@
 *  Refer to LICENSE for more information.
 */
 
-using Java.Nio;
-
 namespace MASES.KNet.Common.Serialization
 {
-    public class UUIDSerializer : Serializer<Uuid>
+    public class UUIDSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<UUIDSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.UUIDSerializer";
 
-        public override bool AutoInit => false;
-
-        public UUIDSerializer()
-            : base(null, null, false)
-        {
-
-        }
+        public byte[] Serialize(string topic, Uuid data) => IExecute<byte[]>("serialize", topic, data);
 
-        public override byte[] Serialize(string topic, Uuid data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<Uuid>(UUIDSerializer t) => t.CastTo<Serializer<Uuid>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidDeserializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidDeserializer.cs
index 17f9a43c25..3dfa0904e3 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidDeserializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidDeserializer.cs
@@ -20,18 +20,12 @@
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class VoidDeserializer : Deserializer<Void>
+    public class VoidDeserializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<VoidDeserializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.VoidDeserializer";
 
-        public override bool AutoInit => false;
+        public Void Deserialize(string topic, byte[] data) => IExecute<Void>("deserialize", topic, data);
 
-        public VoidDeserializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override Void Deserialize(string topic, byte[] data) => IExecute<Void>("deserialize", topic, data);
+        public static implicit operator Deserializer<Void>(VoidDeserializer t) => t.CastTo<Deserializer<Void>>();
     }
 }
diff --git a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidSerializer.cs b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidSerializer.cs
index 823f4fa547..08db647372 100644
--- a/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidSerializer.cs
+++ b/src/net/KNet/ClientSide/BridgedClasses/Common/Serialization/VoidSerializer.cs
@@ -17,22 +17,15 @@
 */
 
 using Java.Lang;
-using Java.Nio;
 
 namespace MASES.KNet.Common.Serialization
 {
-    public class VoidSerializer : Serializer<Void>
+    public class VoidSerializer : MASES.JCOBridge.C2JBridge.JVMBridgeBase<VoidSerializer>
     {
         public override string BridgeClassName => "org.apache.kafka.common.serialization.VoidSerializer";
 
-        public override bool AutoInit => false;
+        public byte[] Serialize(string topic, Void data) => IExecute<byte[]>("serialize", topic, data);
 
-        public VoidSerializer()
-            : base(null, null, false)
-        {
-
-        }
-
-        public override byte[] Serialize(string topic, Void data) => IExecute<byte[]>("serialize", topic, data);
+        public static implicit operator Serializer<Void>(VoidSerializer t) => t.CastTo<Serializer<Void>>();
     }
 }
diff --git a/tests/KNetBenchmark/ProgramKNet.cs b/tests/KNetBenchmark/ProgramKNet.cs
index 2fba3d386c..c5276fd18b 100644
--- a/tests/KNetBenchmark/ProgramKNet.cs
+++ b/tests/KNetBenchmark/ProgramKNet.cs
@@ -52,8 +52,6 @@ static IKNetProducer<long, byte[]> KNetProducer()
                                                         .WithSendBuffer(SocketSendBufferBytes)
                                                         .WithReceiveBuffer(SocketReceiveBufferBytes)
                                                         .WithBufferMemory(128 * 1024 * 1024)
-                                                        .WithKeySerializerClass("org.apache.kafka.common.serialization.LongSerializer")
-                                                        .WithValueSerializerClass("org.apache.kafka.common.serialization.ByteArraySerializer")
                                                         .ToProperties();
 
                 knetKeySerializer = new KNetSerDes<long>(serializeWithHeadersFun: (topic, headers, data) =>
@@ -176,8 +174,6 @@ static IKNetConsumer<long, byte[]> KNetConsumer()
                                                         .WithSendBuffer(SocketSendBufferBytes)
                                                         .WithReceiveBuffer(SocketReceiveBufferBytes)
                                                         .WithFetchMinBytes(FetchMinBytes)
-                                                        .WithKeyDeserializerClass("org.apache.kafka.common.serialization.LongDeserializer")
-                                                        .WithValueDeserializerClass("org.apache.kafka.common.serialization.ByteArrayDeserializer")
                                                         .WithAutoOffsetReset(ConsumerConfig.AutoOffsetReset.EARLIEST)
                                                         .ToProperties();
                 if (UseSerdes)