Enhancement 11

src/java/kafkabridge/pom.xml

@@ -9,7 +9,7 @@
     <name>mases.kafkabridge</name>
     <description>Apache Kafka interface bridging implementation</description>
     <url>https://github.com/masesgroup/KafkaBridge</url>
-    <version>1.1.8.0</version>
+    <version>1.1.9.0</version>
 
     <licenses>
         <license>

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AbortTransactionResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Clients.Admin
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterClientQuotasResult.cs

@@ -18,7 +18,7 @@
 
 using MASES.KafkaBridge.Common;
 using MASES.KafkaBridge.Common.Quota;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterConfigsResult.cs

@@ -18,7 +18,7 @@
 
 using MASES.KafkaBridge.Common;
 using MASES.KafkaBridge.Common.Config;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterConsumerGroupOffsetsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Clients.Admin
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterPartitionReassignmentsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterReplicaLogDirsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/AlterUserScramCredentialsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/CreateAclsResult.cs

@@ -18,7 +18,7 @@
 
 using MASES.KafkaBridge.Common;
 using MASES.KafkaBridge.Common.Acl;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/CreatePartitionsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/CreateTopicsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/DeleteConsumerGroupOffsetsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Clients.Admin
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/DeleteConsumerGroupsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/DeleteRecordsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/DeleteTopicsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/ElectLeadersResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/ListConsumerGroupsResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/RemoveMembersFromConsumerGroupResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Clients.Admin
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/UnregisterBrokerResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Clients.Admin
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Admin/UpdateFeaturesResult.cs

@@ -17,7 +17,7 @@
 */
 
 using MASES.KafkaBridge.Common;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Clients.Admin

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Consumer/ConsumerRebalanceListener.cs

@@ -41,12 +41,12 @@ public interface IConsumerRebalanceListener : IJVMBridgeBase
     }
 
     /// <summary>
-    /// Listener for Kafka ConsumerRebalanceListener. Extends <see cref="CLRListener"/>, implements <see cref="IConsumerRebalanceListener"/>
+    /// Listener for Kafka ConsumerRebalanceListener. Extends <see cref="JVMBridgeListener"/>, implements <see cref="IConsumerRebalanceListener"/>
     /// </summary>
     /// <remarks>Remember to Dispose the object otherwise there is a resource leak, the object contains a reference to the the corresponding JVM object</remarks>
-    public class ConsumerRebalanceListener : CLRListener, IConsumerRebalanceListener
+    public class ConsumerRebalanceListener : JVMBridgeListener, IConsumerRebalanceListener
     {
-        /// <inheritdoc cref="CLRListener.ClassName"/>
+        /// <inheritdoc cref="JVMBridgeListener.ClassName"/>
         public sealed override string ClassName => "org.mases.kafkabridge.clients.consumer.ConsumerRebalanceListenerImpl";
 
         readonly Action<Collection<TopicPartition>> revokedFunction = null;

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Consumer/OffsetCommitCallback.cs

@@ -38,12 +38,12 @@ public interface IOffsetCommitCallback : IJVMBridgeBase
     }
 
     /// <summary>
-    /// Listener for Kafka OffsetCommitCallback. Extends <see cref="CLRListener"/>, implements <see cref="IOffsetCommitCallback"/>
+    /// Listener for Kafka OffsetCommitCallback. Extends <see cref="JVMBridgeListener"/>, implements <see cref="IOffsetCommitCallback"/>
     /// </summary>
     /// <remarks>Remember to Dispose the object otherwise there is a resource leak, the object contains a reference to the the corresponding JVM object</remarks>
-    public class OffsetCommitCallback : CLRListener, IOffsetCommitCallback
+    public class OffsetCommitCallback : JVMBridgeListener, IOffsetCommitCallback
     {
-        /// <inheritdoc cref="CLRListener.ClassName"/>
+        /// <inheritdoc cref="JVMBridgeListener.ClassName"/>
         public sealed override string ClassName => "org.mases.kafkabridge.clients.consumer.OffsetCommitCallbackImpl";
 
         readonly Action<Map<TopicPartition, OffsetAndMetadata>, JVMBridgeException> executionFunction = null;

src/net/KafkaBridge/ClientSide/BridgedClasses/Clients/Producer/Callback.cs

@@ -36,12 +36,12 @@ public interface ICallback : IJVMBridgeBase
     }
 
     /// <summary>
-    /// Listener for Kafka Callback. Extends <see cref="CLRListener"/>, implements <see cref="ICallback"/>
+    /// Listener for Kafka Callback. Extends <see cref="JVMBridgeListener"/>, implements <see cref="ICallback"/>
     /// </summary>
     /// <remarks>Remember to Dispose the object otherwise there is a resource leak, the object contains a reference to the the corresponding JVM object</remarks>
-    public class Callback : CLRListener, ICallback
+    public class Callback : JVMBridgeListener, ICallback
     {
-        /// <inheritdoc cref="CLRListener.ClassName"/>
+        /// <inheritdoc cref="JVMBridgeListener.ClassName"/>
         public sealed override string ClassName => "org.mases.kafkabridge.clients.producer.CallbackImpl";
 
         readonly Action<RecordMetadata, JVMBridgeException> executionFunction = null;

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/KafkaFuture.cs

@@ -16,7 +16,7 @@
 *  Refer to LICENSE for more information.
 */
 
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 using MASES.KafkaBridge.Java.Util.Concurrent;
 
 namespace MASES.KafkaBridge.Common

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Serialization/Deserializer.cs

@@ -58,9 +58,9 @@ public interface IDeserializer<E> : IDeserializer
     /// </summary>
     /// <typeparam name="E">The data associated to the event</typeparam>
     /// <remarks>Remember to Dispose the object otherwise there is a resource leak, the object contains a reference to the the corresponding JVM object</remarks>
-    public class Deserializer<E> : CLRListener, IDeserializer<E>
+    public class Deserializer<E> : JVMBridgeListener, IDeserializer<E>
     {
-        /// <inheritdoc cref="CLRListener.ClassName"/>
+        /// <inheritdoc cref="JVMBridgeListener.ClassName"/>
         public override string ClassName => "org.mases.kafkabridge.clients.common.serialization.DeserializerImpl";
 
         readonly Func<string, byte[], E> deserialize = null;

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Serialization/Serdes.cs

@@ -17,7 +17,8 @@
 */
 
 using MASES.KafkaBridge.Common.Utils;
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
+using MASES.KafkaBridge.Java.Util;
 
 namespace MASES.KafkaBridge.Common.Serialization
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Serialization/Serializer.cs

@@ -54,13 +54,13 @@ public interface ISerializer<E> : ISerializer
         byte[] SerializeWithHeaders(string topic, Headers headers, E data);
     }
     /// <summary>
-    /// Listener for Kafka Serializer. Extends <see cref="CLRListener"/>. Implements <see cref="ISerializer{E}"/>
+    /// Listener for Kafka Serializer. Extends <see cref="JVMBridgeListener"/>. Implements <see cref="ISerializer{E}"/>
     /// </summary>
     /// <typeparam name="E">The data associated to the event</typeparam>
     /// <remarks>Remember to Dispose the object otherwise there is a resource leak, the object contains a reference to the the corresponding JVM object</remarks>
-    public class Serializer<E> : CLRListener, ISerializer<E>
+    public class Serializer<E> : JVMBridgeListener, ISerializer<E>
     {
-        /// <inheritdoc cref="CLRListener.ClassName"/>
+        /// <inheritdoc cref="JVMBridgeListener.ClassName"/>
         public override string ClassName => "org.mases.kafkabridge.clients.common.serialization.SerializerImpl";
 
         readonly Func<string, E, byte[]> serialize = null;

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Serialization/VoidDeserializer.cs

@@ -16,7 +16,7 @@
 *  Refer to LICENSE for more information.
 */
 
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Common.Serialization
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Serialization/VoidSerializer.cs

@@ -16,7 +16,7 @@
 *  Refer to LICENSE for more information.
 */
 
-using MASES.KafkaBridge.Java.Lang;
+using Java.Lang;
 
 namespace MASES.KafkaBridge.Common.Serialization
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Common/Utils/Time.cs

@@ -16,8 +16,8 @@
 *  Refer to LICENSE for more information.
 */
 
+using Java.Util.Function;
 using MASES.JCOBridge.C2JBridge;
-using MASES.JCOBridge.C2JBridge.Function;
 
 namespace MASES.KafkaBridge.Common.Utils
 {

src/net/KafkaBridge/ClientSide/BridgedClasses/Connect/Data/ConnectSchema.cs

@@ -17,6 +17,7 @@
 */
 
 using MASES.KafkaBridge.Java.Util;
+using JavaLang = Java.Lang;
 
 namespace MASES.KafkaBridge.Connect.Data
 {
@@ -30,12 +31,12 @@ public ConnectSchema()
         {
         }
 
-        public ConnectSchema(Type type, bool optional, Java.Lang.Object defaultValue, string name, int version, string doc, Map<string, string> parameters, List<Field> fields, Schema keySchema, Schema valueSchema)
+        public ConnectSchema(Type type, bool optional, JavaLang.Object defaultValue, string name, int version, string doc, Map<string, string> parameters, List<Field> fields, Schema keySchema, Schema valueSchema)
             : base(type, optional, defaultValue, name, version, doc, parameters, fields, keySchema, valueSchema)
         {
         }
 
-        public ConnectSchema(Type type, bool optional, Java.Lang.Object defaultValue, string name, int version, string doc)
+        public ConnectSchema(Type type, bool optional, JavaLang.Object defaultValue, string name, int version, string doc)
             :this(type, optional, defaultValue, name, version, doc, null, null, null, null)
         {
         }

src/net/KafkaBridge/ClientSide/BridgedClasses/Connect/Data/Schema.cs

@@ -18,6 +18,7 @@
 
 using MASES.JCOBridge.C2JBridge;
 using MASES.KafkaBridge.Java.Util;
+using JavaLang = Java.Lang;
 
 namespace MASES.KafkaBridge.Connect.Data
 {
@@ -91,7 +92,7 @@ public interface ISchema : IJVMBridgeBase
 
         bool IsOptional { get; }
 
-        Java.Lang.Object DefaultValue();
+        JavaLang.Object DefaultValue();
 
         string Name();
 
@@ -131,7 +132,7 @@ public Schema(params object[] args)
 
         public bool IsOptional => IExecute<bool>("isOptional");
 
-        public Java.Lang.Object DefaultValue() { return IExecute<Java.Lang.Object>("defaultValue"); }
+        public JavaLang.Object DefaultValue() { return IExecute<JavaLang.Object>("defaultValue"); }
 
         public string Name() { return IExecute<string>("name"); }
 

src/net/KafkaBridge/ClientSide/BridgedClasses/Connect/Data/SchemaAndValue.cs

@@ -17,6 +17,7 @@
 */
 
 using MASES.JCOBridge.C2JBridge;
+using JavaLang = Java.Lang;
 
 namespace MASES.KafkaBridge.Connect.Data
 {
@@ -30,13 +31,13 @@ public SchemaAndValue()
         {
         }
 
-        public SchemaAndValue(Schema schema, Java.Lang.Object value)
+        public SchemaAndValue(Schema schema, JavaLang.Object value)
             :base(schema, value)
         {
         }
 
         public Schema Schema => IExecute<Schema>("schema");
 
-        public Java.Lang.Object Value => IExecute<Java.Lang.Object>("value");
+        public JavaLang.Object Value => IExecute<JavaLang.Object>("value");
     }
 }

src/net/KafkaBridge/ClientSide/BridgedClasses/Connect/Data/SchemaProjector.cs

@@ -17,16 +17,17 @@
 */
 
 using MASES.JCOBridge.C2JBridge;
+using JavaLang = Java.Lang;
 
 namespace MASES.KafkaBridge.Connect.Data
 {
     public class SchemaProjector : JVMBridgeBase<SchemaProjector>
     {
         public override string ClassName => "org.apache.kafka.connect.data.SchemaProjector";
 
-        public static Java.Lang.Object Project(Schema source, Java.Lang.Object record, Schema target)
+        public static JavaLang.Object Project(Schema source, JavaLang.Object record, Schema target)
         {
-            return SExecute<Java.Lang.Object>("project", source, record, target);
+            return SExecute<JavaLang.Object>("project", source, record, target);
         }
     }
 }