diff --git a/src/config/connect-log4j.properties b/src/config/connect-log4j.properties
index 157d5931b6..2e049a50b8 100644
--- a/src/config/connect-log4j.properties
+++ b/src/config/connect-log4j.properties
@@ -38,5 +38,4 @@ connect.log.pattern=[%d] %p %X{connector.context}%m (%c:%L)%n
log4j.appender.stdout.layout.ConversionPattern=${connect.log.pattern}
log4j.appender.connectAppender.layout.ConversionPattern=${connect.log.pattern}
-log4j.logger.org.apache.zookeeper=ERROR
log4j.logger.org.reflections=ERROR
diff --git a/src/config/kraft/broker.properties b/src/config/kraft/broker.properties
index 4edcc126d6..2d15997f28 100644
--- a/src/config/kraft/broker.properties
+++ b/src/config/kraft/broker.properties
@@ -15,7 +15,7 @@
#
# This configuration file is intended for use in KRaft mode, where
-# Apache ZooKeeper is not present. See config/kraft/README.md for details.
+# Apache ZooKeeper is not present.
#
############################# Server Basics #############################
diff --git a/src/config/kraft/controller.properties b/src/config/kraft/controller.properties
index 9e8ad62054..9d152f7829 100644
--- a/src/config/kraft/controller.properties
+++ b/src/config/kraft/controller.properties
@@ -15,7 +15,7 @@
#
# This configuration file is intended for use in KRaft mode, where
-# Apache ZooKeeper is not present. See config/kraft/README.md for details.
+# Apache ZooKeeper is not present.
#
############################# Server Basics #############################
diff --git a/src/config/kraft/server.properties b/src/config/kraft/server.properties
index ea84818b0c..6461c988d3 100644
--- a/src/config/kraft/server.properties
+++ b/src/config/kraft/server.properties
@@ -15,7 +15,7 @@
#
# This configuration file is intended for use in KRaft mode, where
-# Apache ZooKeeper is not present. See config/kraft/README.md for details.
+# Apache ZooKeeper is not present.
#
############################# Server Basics #############################
diff --git a/src/config/tools-log4j.properties b/src/config/tools-log4j.properties
index b19e343265..b669a4e638 100644
--- a/src/config/tools-log4j.properties
+++ b/src/config/tools-log4j.properties
@@ -19,3 +19,6 @@ log4j.appender.stderr=org.apache.log4j.ConsoleAppender
log4j.appender.stderr.layout=org.apache.log4j.PatternLayout
log4j.appender.stderr.layout.ConversionPattern=[%d] %p %m (%c)%n
log4j.appender.stderr.Target=System.err
+
+# for connect-plugin-path
+log4j.logger.org.reflections=ERROR
diff --git a/src/configuration.json b/src/configuration.json
index 8ec72625e2..8e1dce8691 100644
--- a/src/configuration.json
+++ b/src/configuration.json
@@ -4,62 +4,62 @@
"DisableInterfaceMethodGeneration": true,
"CreateInterfaceInheritance": true,
"JarList": [
- "kafka_2.13-3.5.1.jar",
- "kafka-clients-3.5.1.jar",
- "kafka-streams-3.5.1.jar",
- "kafka-tools-3.5.1.jar",
- "connect-api-3.5.1.jar",
- "connect-basic-auth-extension-3.5.1.jar",
- "connect-json-3.5.1.jar",
- "connect-mirror-3.5.1.jar",
- "connect-mirror-client-3.5.1.jar",
- "connect-runtime-3.5.1.jar",
- "connect-transforms-3.5.1.jar"
+ "kafka_2.13-3.6.0.jar",
+ "kafka-clients-3.6.0.jar",
+ "kafka-streams-3.6.0.jar",
+ "kafka-tools-3.6.0.jar",
+ "connect-api-3.6.0.jar",
+ "connect-basic-auth-extension-3.6.0.jar",
+ "connect-json-3.6.0.jar",
+ "connect-mirror-3.6.0.jar",
+ "connect-mirror-client-3.6.0.jar",
+ "connect-runtime-3.6.0.jar",
+ "connect-transforms-3.6.0.jar"
],
"OriginJavadocJARVersionAndUrls": [
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka_2.13/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka_2.13/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-basic-auth-extension/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-basic-auth-extension/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-json/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-json/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-mirror/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-mirror-client/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/3.6.0/"
},
{
"Version": 8,
- "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-transforms/3.5.1/"
+ "Url": "https://www.javadoc.io/doc/org.apache.kafka/connect-transforms/3.6.0/"
}
],
"NamespacesToAvoid": [
@@ -200,8 +200,11 @@
"org.apache.kafka.streams.processor.api.ProcessorSupplier",
"org.apache.kafka.tools.ClientCompatibilityTest$ClientCompatibilityTestDeserializer",
"org.apache.kafka.tools.ConsumerPerformance$ConsumerPerfRebListener",
+ "org.apache.kafka.tools.ThroughputThrottler",
"org.apache.kafka.tools.VerifiableConsumer$RecordData",
"org.apache.kafka.tools.VerifiableConsumer$RecordsConsumed",
+ "org.apache.kafka.tools.reassign.LogDirMoveState",
+ "org.apache.kafka.tools.reassign.PartitionReassignmentState",
"org.apache.zookeeper.ZooKeeperMainWithTlsSupportForKafka",
"org.apache.zookeeper.server.quorum.QuorumPeerMain"
]
diff --git a/src/documentation/articles/commandlineswitch.md b/src/documentation/articles/commandlineswitch.md
index ed5eacb803..a6142789aa 100644
--- a/src/documentation/articles/commandlineswitch.md
+++ b/src/documentation/articles/commandlineswitch.md
@@ -59,20 +59,5 @@ Plus it accepts from:
## JVM identification
-One of the most important command-line switch is **JVMPath** and it is available in [JCOBridge switches](https://www.jcobridge.com/net-examples/command-line-options/): it can be used to set-up the location of the JVM library if JCOBridge is not able to identify a suitable JRE installation.
-If a developer is using KNet within its own product it is possible to override the **JVMPath** property with a snippet like the following one:
-
-```c#
- class MyKNetCore : KNetCore
- {
- public override string JVMPath
- {
- get
- {
- string pathToJVM = "Set here the path to JVM library or use your own search method";
- return pathToJVM;
- }
- }
- }
-```
+One of the most important command-line switch is **JVMPath**: see [KNet usage](usage.md) to find more information.
diff --git a/src/java/knet/pom.xml b/src/java/knet/pom.xml
index f7310ed4c4..fec71ebc6c 100644
--- a/src/java/knet/pom.xml
+++ b/src/java/knet/pom.xml
@@ -40,7 +40,7 @@
11
11
${basedir}/classpathfile.classpath
- 3.5.1
+ 3.6.0
2.1.3.0
2.5.8
diff --git a/src/net/KNet/Developed/Kafka/Tools/ClusterTool.cs b/src/net/KNet/Developed/Kafka/Tools/ClusterTool.cs
deleted file mode 100644
index 7bce3f626e..0000000000
--- a/src/net/KNet/Developed/Kafka/Tools/ClusterTool.cs
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-namespace Kafka.Tools
-{
- ///
- /// Class managing ClusterTool
- ///
- public class ClusterTool : MASES.JCOBridge.C2JBridge.JVMBridgeMain
- {
- ///
- /// Initialize a new
- ///
- public ClusterTool()
- : base("kafka.tools.ClusterTool")
- {
- }
- }
-}
diff --git a/src/net/KNet/Developed/Kafka/Tools/ConsumerPerformance.cs b/src/net/KNet/Developed/Kafka/Tools/ConsumerPerformance.cs
deleted file mode 100644
index a1dcbbb94f..0000000000
--- a/src/net/KNet/Developed/Kafka/Tools/ConsumerPerformance.cs
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-namespace Kafka.Tools
-{
- ///
- /// Class managing ConsumerPerformance
- ///
- public class ConsumerPerformance : MASES.JCOBridge.C2JBridge.JVMBridgeMain
- {
- ///
- /// Initialize a new
- ///
- public ConsumerPerformance()
- : base("kafka.tools.ConsumerPerformance")
- {
- }
- }
-}
diff --git a/src/net/KNet/Developed/Kafka/Tools/StreamsResetter.cs b/src/net/KNet/Developed/Kafka/Tools/StreamsResetter.cs
deleted file mode 100644
index 7c47aec886..0000000000
--- a/src/net/KNet/Developed/Kafka/Tools/StreamsResetter.cs
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-namespace Kafka.Tools
-{
- ///
- /// Class managing StreamsResetter
- ///
- public class StreamsResetter : MASES.JCOBridge.C2JBridge.JVMBridgeMain
- {
- ///
- /// Initialize a new
- ///
- public StreamsResetter()
- : base("kafka.tools.StreamsResetter")
- {
- }
- }
-}
diff --git a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
index 18e6ccefdf..048df0a266 100644
--- a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class AclCommand
#region Static methods
///
- ///
+ ///
///
///
@@ -51,7 +51,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -60,7 +60,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
@@ -69,7 +69,7 @@ public static string AuthorizerDeprecationMessage()
return SExecute(LocalBridgeClazz, "AuthorizerDeprecationMessage");
}
///
- ///
+ ///
///
///
@@ -78,7 +78,7 @@ public static Org.Apache.Kafka.Common.Resource.ResourcePatternFilter ClusterReso
return SExecute(LocalBridgeClazz, "ClusterResourceFilter");
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -98,7 +98,7 @@ public partial class AclCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public AclCommandOptions(string[] args)
@@ -122,7 +122,7 @@ public AclCommandOptions(string[] args)
#region Instance methods
///
- ///
+ ///
///
///
@@ -131,7 +131,7 @@ public string CommandConfigDoc()
return IExecute("CommandConfigDoc");
}
///
- ///
+ ///
///
public void CheckArgs()
{
@@ -169,21 +169,21 @@ public partial class AclCommandService
#region Instance methods
///
- ///
+ ///
///
public void AddAcls()
{
IExecute("addAcls");
}
///
- ///
+ ///
///
public void ListAcls()
{
IExecute("listAcls");
}
///
- ///
+ ///
///
public void RemoveAcls()
{
@@ -205,7 +205,7 @@ public partial class AdminClientService
{
#region Constructors
///
- ///
+ ///
///
///
public AdminClientService(Kafka.Admin.AclCommand.AclCommandOptions opts)
@@ -229,7 +229,7 @@ public AdminClientService(Kafka.Admin.AclCommand.AclCommandOptions opts)
#region Instance methods
///
- ///
+ ///
///
///
@@ -238,7 +238,7 @@ public bool IsDebugEnabled()
return IExecute("isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -247,7 +247,7 @@ public bool IsTraceEnabled()
return IExecute("isTraceEnabled");
}
///
- ///
+ ///
///
///
@@ -256,7 +256,7 @@ public string LoggerName()
return IExecute("loggerName");
}
///
- ///
+ ///
///
///
@@ -265,7 +265,7 @@ public string LogIdent()
return IExecute("logIdent");
}
///
- ///
+ ///
///
///
///
@@ -274,7 +274,7 @@ public string MsgWithLogIdent(string msg)
return IExecute("msgWithLogIdent", msg);
}
///
- ///
+ ///
///
///
@@ -283,21 +283,21 @@ public Kafka.Admin.AclCommand.AclCommandOptions Opts()
return IExecute("opts");
}
///
- ///
+ ///
///
public void AddAcls()
{
IExecute("addAcls");
}
///
- ///
+ ///
///
public void ListAcls()
{
IExecute("listAcls");
}
///
- ///
+ ///
///
public void RemoveAcls()
{
@@ -319,7 +319,7 @@ public partial class AuthorizerService
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -344,7 +344,7 @@ public AuthorizerService(string authorizerClassName, Kafka.Admin.AclCommand.AclC
#region Instance methods
///
- ///
+ ///
///
///
@@ -353,7 +353,7 @@ public bool IsDebugEnabled()
return IExecute("isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -362,7 +362,7 @@ public bool IsTraceEnabled()
return IExecute("isTraceEnabled");
}
///
- ///
+ ///
///
///
@@ -371,7 +371,7 @@ public string AuthorizerClassName()
return IExecute("authorizerClassName");
}
///
- ///
+ ///
///
///
@@ -380,7 +380,7 @@ public string LoggerName()
return IExecute("loggerName");
}
///
- ///
+ ///
///
///
@@ -389,7 +389,7 @@ public string LogIdent()
return IExecute("logIdent");
}
///
- ///
+ ///
///
///
///
@@ -398,7 +398,7 @@ public string MsgWithLogIdent(string msg)
return IExecute("msgWithLogIdent", msg);
}
///
- ///
+ ///
///
///
@@ -407,21 +407,21 @@ public Kafka.Admin.AclCommand.AclCommandOptions Opts()
return IExecute("opts");
}
///
- ///
+ ///
///
public void AddAcls()
{
IExecute("addAcls");
}
///
- ///
+ ///
///
public void ListAcls()
{
IExecute("listAcls");
}
///
- ///
+ ///
///
public void RemoveAcls()
{
diff --git a/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs b/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
index 088d0466d6..241609fb6b 100644
--- a/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge.JVMInterop;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region AclCommand
///
- ///
+ ///
///
public partial class AclCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -66,7 +66,7 @@ public AclCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region AclCommandOptions
///
- ///
+ ///
///
public partial class AclCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -109,7 +109,7 @@ public AclCommandOptions(params object[] args) : base(args) { }
#region AclCommandService
///
- ///
+ ///
///
public partial class AclCommandService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -152,7 +152,7 @@ public AclCommandService(params object[] args) : base(args) { }
#region AdminClientService
///
- ///
+ ///
///
public partial class AdminClientService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -195,7 +195,7 @@ public AdminClientService(params object[] args) : base(args) { }
#region AuthorizerService
///
- ///
+ ///
///
public partial class AuthorizerService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -240,68 +240,9 @@ public AuthorizerService(params object[] args) : base(args) { }
}
#endregion
- #region AdminOperationException
- ///
- ///
- ///
- public partial class AdminOperationException : Java.Lang.RuntimeException
- {
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.AdminOperationException";
-
- // TODO: complete the class
-
- }
- #endregion
-
- #region AdminUtils
- ///
- ///
- ///
- public partial class AdminUtils : MASES.JCOBridge.C2JBridge.JVMBridgeBase
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public AdminUtils() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public AdminUtils(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.AdminUtils");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.AdminUtils";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => false;
-
- // TODO: complete the class
-
- }
- #endregion
-
#region BrokerApiVersionsCommand
///
- ///
+ ///
///
public partial class BrokerApiVersionsCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -340,7 +281,7 @@ public BrokerApiVersionsCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region BrokerVersionCommandOptions
///
- ///
+ ///
///
public partial class BrokerVersionCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -385,52 +326,9 @@ public BrokerVersionCommandOptions(params object[] args) : base(args) { }
}
#endregion
- #region BrokerMetadata
- ///
- ///
- ///
- public partial class BrokerMetadata : MASES.JCOBridge.C2JBridge.JVMBridgeBase
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public BrokerMetadata() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public BrokerMetadata(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.BrokerMetadata");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.BrokerMetadata";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => false;
-
- // TODO: complete the class
-
- }
- #endregion
-
#region ConfigCommand
///
- ///
+ ///
///
public partial class ConfigCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -469,7 +367,7 @@ public ConfigCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region ConfigCommandOptions
///
- ///
+ ///
///
public partial class ConfigCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -512,7 +410,7 @@ public ConfigCommandOptions(params object[] args) : base(args) { }
#region ConfigEntity
///
- ///
+ ///
///
public partial class ConfigEntity : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -555,7 +453,7 @@ public ConfigEntity(params object[] args) : base(args) { }
#region Entity
///
- ///
+ ///
///
public partial class Entity : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -602,7 +500,7 @@ public Entity(params object[] args) : base(args) { }
#region ConsumerGroupCommand
///
- ///
+ ///
///
public partial class ConsumerGroupCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -641,7 +539,7 @@ public ConsumerGroupCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region ConsumerGroupCommandOptions
///
- ///
+ ///
///
public partial class ConsumerGroupCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -684,7 +582,7 @@ public ConsumerGroupCommandOptions(params object[] args) : base(args) { }
#region ConsumerGroupService
///
- ///
+ ///
///
public partial class ConsumerGroupService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -727,7 +625,7 @@ public ConsumerGroupService(params object[] args) : base(args) { }
#region CsvRecord
///
- ///
+ ///
///
public partial class CsvRecord : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -770,7 +668,7 @@ public CsvRecord(params object[] args) : base(args) { }
#region CsvRecordNoGroup
///
- ///
+ ///
///
public partial class CsvRecordNoGroup : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -813,7 +711,7 @@ public CsvRecordNoGroup(params object[] args) : base(args) { }
#region CsvRecordWithGroup
///
- ///
+ ///
///
public partial class CsvRecordWithGroup : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -856,7 +754,7 @@ public CsvRecordWithGroup(params object[] args) : base(args) { }
#region CsvUtils
///
- ///
+ ///
///
public partial class CsvUtils : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -899,7 +797,7 @@ public CsvUtils(params object[] args) : base(args) { }
#region GroupState
///
- ///
+ ///
///
public partial class GroupState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -942,7 +840,7 @@ public GroupState(params object[] args) : base(args) { }
#region LogOffsetResult
///
- ///
+ ///
///
public partial class LogOffsetResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -985,7 +883,7 @@ public LogOffsetResult(params object[] args) : base(args) { }
#region MemberAssignmentState
///
- ///
+ ///
///
public partial class MemberAssignmentState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1028,7 +926,7 @@ public MemberAssignmentState(params object[] args) : base(args) { }
#region PartitionAssignmentState
///
- ///
+ ///
///
public partial class PartitionAssignmentState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1070,98 +968,12 @@ public PartitionAssignmentState(params object[] args) : base(args) { }
#endregion
- }
- #endregion
-
- #region DeleteRecordsCommand
- ///
- ///
- ///
- public partial class DeleteRecordsCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public DeleteRecordsCommand() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public DeleteRecordsCommand(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.DeleteRecordsCommand");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.DeleteRecordsCommand";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => false;
-
- // TODO: complete the class
- #region DeleteRecordsCommandOptions
- ///
- ///
- ///
- public partial class DeleteRecordsCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public DeleteRecordsCommandOptions() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public DeleteRecordsCommandOptions(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.DeleteRecordsCommand$DeleteRecordsCommandOptions");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.DeleteRecordsCommand$DeleteRecordsCommandOptions";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => true;
-
- // TODO: complete the class
-
- }
- #endregion
-
-
}
#endregion
#region FeatureCommand
///
- ///
+ ///
///
public partial class FeatureCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -1204,7 +1016,7 @@ public FeatureCommand(params object[] args) : base(args) { }
#region LeaderElectionCommand
///
- ///
+ ///
///
public partial class LeaderElectionCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -1247,7 +1059,7 @@ public LeaderElectionCommand(params object[] args) : base(args) { }
#region LeaderElectionCommandOptions
///
- ///
+ ///
///
public partial class LeaderElectionCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1288,95 +1100,9 @@ public LeaderElectionCommandOptions(params object[] args) : base(args) { }
}
#endregion
- #region LogDirsCommand
- ///
- ///
- ///
- public partial class LogDirsCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public LogDirsCommand() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public LogDirsCommand(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.LogDirsCommand");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.LogDirsCommand";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => false;
-
- // TODO: complete the class
- #region LogDirsCommandOptions
- ///
- ///
- ///
- public partial class LogDirsCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
- {
- ///
- /// Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
- ///
- public LogDirsCommandOptions() { }
- ///
- /// Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
- ///
- public LogDirsCommandOptions(params object[] args) : base(args) { }
-
- private static readonly IJavaType LocalBridgeClazz = ClazzOf("kafka.admin.LogDirsCommand$LogDirsCommandOptions");
-
- ///
- ///
- ///
- public override string BridgeClassName => "kafka.admin.LogDirsCommand$LogDirsCommandOptions";
- ///
- ///
- ///
- public override bool IsBridgeAbstract => false;
- ///
- ///
- ///
- public override bool IsBridgeCloseable => false;
- ///
- ///
- ///
- public override bool IsBridgeInterface => false;
- ///
- ///
- ///
- public override bool IsBridgeStatic => true;
-
- // TODO: complete the class
-
- }
- #endregion
-
-
- }
- #endregion
-
#region RackAwareMode
///
- ///
+ ///
///
public partial class RackAwareMode : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1419,7 +1145,7 @@ public RackAwareMode(params object[] args) : base(args) { }
#region ReassignPartitionsCommand
///
- ///
+ ///
///
public partial class ReassignPartitionsCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -1458,7 +1184,7 @@ public ReassignPartitionsCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region ActiveMoveState
///
- ///
+ ///
///
public partial class ActiveMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1501,7 +1227,7 @@ public ActiveMoveState(params object[] args) : base(args) { }
#region CancelledMoveState
///
- ///
+ ///
///
public partial class CancelledMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1544,7 +1270,7 @@ public CancelledMoveState(params object[] args) : base(args) { }
#region CompletedMoveState
///
- ///
+ ///
///
public partial class CompletedMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1587,7 +1313,7 @@ public CompletedMoveState(params object[] args) : base(args) { }
#region LogDirMoveState
///
- ///
+ ///
///
public partial class LogDirMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1630,7 +1356,7 @@ public LogDirMoveState(params object[] args) : base(args) { }
#region MissingLogDirMoveState
///
- ///
+ ///
///
public partial class MissingLogDirMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1673,7 +1399,7 @@ public MissingLogDirMoveState(params object[] args) : base(args) { }
#region MissingReplicaMoveState
///
- ///
+ ///
///
public partial class MissingReplicaMoveState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1716,7 +1442,7 @@ public MissingReplicaMoveState(params object[] args) : base(args) { }
#region PartitionMove
///
- ///
+ ///
///
public partial class PartitionMove : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1759,7 +1485,7 @@ public PartitionMove(params object[] args) : base(args) { }
#region PartitionReassignmentState
///
- ///
+ ///
///
public partial class PartitionReassignmentState : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1802,7 +1528,7 @@ public PartitionReassignmentState(params object[] args) : base(args) { }
#region ReassignPartitionsCommandOptions
///
- ///
+ ///
///
public partial class ReassignPartitionsCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1845,7 +1571,7 @@ public ReassignPartitionsCommandOptions(params object[] args) : base(args) { }
#region TerseReassignmentFailureException
///
- ///
+ ///
///
public partial class TerseReassignmentFailureException : Org.Apache.Kafka.Common.KafkaException
{
@@ -1861,7 +1587,7 @@ public partial class TerseReassignmentFailureException : Org.Apache.Kafka.Common
#region VerifyAssignmentResult
///
- ///
+ ///
///
public partial class VerifyAssignmentResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1908,7 +1634,7 @@ public VerifyAssignmentResult(params object[] args) : base(args) { }
#region TopicCommand
///
- ///
+ ///
///
public partial class TopicCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -1947,7 +1673,7 @@ public TopicCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region CommandTopicPartition
///
- ///
+ ///
///
public partial class CommandTopicPartition : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -1990,7 +1716,7 @@ public CommandTopicPartition(params object[] args) : base(args) { }
#region DescribeOptions
///
- ///
+ ///
///
public partial class DescribeOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -2033,7 +1759,7 @@ public DescribeOptions(params object[] args) : base(args) { }
#region PartitionDescription
///
- ///
+ ///
///
public partial class PartitionDescription : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -2076,7 +1802,7 @@ public PartitionDescription(params object[] args) : base(args) { }
#region TopicCommandOptions
///
- ///
+ ///
///
public partial class TopicCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -2119,7 +1845,7 @@ public TopicCommandOptions(params object[] args) : base(args) { }
#region TopicDescription
///
- ///
+ ///
///
public partial class TopicDescription : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -2162,7 +1888,7 @@ public TopicDescription(params object[] args) : base(args) { }
#region TopicService
///
- ///
+ ///
///
public partial class TopicService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -2209,7 +1935,7 @@ public TopicService(params object[] args) : base(args) { }
#region ZkSecurityMigrator
///
- ///
+ ///
///
public partial class ZkSecurityMigrator : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
diff --git a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
index ad670cd5b7..f5da558cea 100644
--- a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class BrokerApiVersionsCommand
#region Static methods
///
- ///
+ ///
///
///
///
@@ -51,7 +51,7 @@ public static void Execute(string[] args, Java.Io.PrintStream _out)
SExecute(LocalBridgeClazz, "execute", args, _out);
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -71,7 +71,7 @@ public partial class BrokerVersionCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public BrokerVersionCommandOptions(string[] args)
@@ -95,7 +95,7 @@ public BrokerVersionCommandOptions(string[] args)
#region Instance methods
///
- ///
+ ///
///
///
@@ -104,7 +104,7 @@ public string BootstrapServerDoc()
return IExecute("BootstrapServerDoc");
}
///
- ///
+ ///
///
///
@@ -113,7 +113,7 @@ public string CommandConfigDoc()
return IExecute("CommandConfigDoc");
}
///
- ///
+ ///
///
public void CheckArgs()
{
diff --git a/src/net/KNet/Generated/Kafka/Admin/BrokerMetadata.cs b/src/net/KNet/Generated/Kafka/Admin/BrokerMetadata.cs
deleted file mode 100644
index ab09049a56..0000000000
--- a/src/net/KNet/Generated/Kafka/Admin/BrokerMetadata.cs
+++ /dev/null
@@ -1,116 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-/*
-* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
-*/
-
-using MASES.JCOBridge.C2JBridge;
-
-namespace Kafka.Admin
-{
- #region BrokerMetadata
- public partial class BrokerMetadata : Java.Io.ISerializable
- {
- #region Constructors
-
- #endregion
-
- #region Class/Interface conversion operators
- ///
- /// Converter from to
- ///
- public static implicit operator Java.Io.Serializable(Kafka.Admin.BrokerMetadata t) => t.Cast();
-
- #endregion
-
- #region Fields
-
- #endregion
-
- #region Static methods
-
- #endregion
-
- #region Instance methods
- ///
- ///
- ///
- ///
- ///
- public bool CanEqual(object x_1)
- {
- return IExecute("canEqual", x_1);
- }
- ///
- ///
- ///
-
- ///
- public int Id()
- {
- return IExecute("id");
- }
- ///
- ///
- ///
-
- ///
- public int ProductArity()
- {
- return IExecute("productArity");
- }
- ///
- ///
- ///
- ///
- ///
- public object ProductElement(int x_1)
- {
- return IExecute("productElement", x_1);
- }
- ///
- ///
- ///
- ///
- ///
- public string ProductElementName(int x_1)
- {
- return IExecute("productElementName", x_1);
- }
- ///
- ///
- ///
-
- ///
- public string ProductPrefix()
- {
- return IExecute("productPrefix");
- }
-
- #endregion
-
- #region Nested classes
-
- #endregion
-
- // TODO: complete the class
- }
- #endregion
-}
\ No newline at end of file
diff --git a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
index 7ca3268d74..19dc3088fd 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class ConfigCommand
#region Static methods
///
- ///
+ ///
///
///
@@ -51,7 +51,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -60,7 +60,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
@@ -69,7 +69,7 @@ public static int DefaultScramIterations()
return SExecute(LocalBridgeClazz, "DefaultScramIterations");
}
///
- ///
+ ///
///
///
@@ -78,7 +78,7 @@ public static string BrokerDefaultEntityName()
return SExecute(LocalBridgeClazz, "BrokerDefaultEntityName");
}
///
- ///
+ ///
///
///
@@ -87,7 +87,7 @@ public static string BrokerLoggerConfigType()
return SExecute(LocalBridgeClazz, "BrokerLoggerConfigType");
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -107,7 +107,7 @@ public partial class ConfigCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public ConfigCommandOptions(string[] args)
@@ -131,7 +131,7 @@ public ConfigCommandOptions(string[] args)
#region Instance methods
///
- ///
+ ///
///
///
@@ -140,7 +140,7 @@ public string Nl()
return IExecute("nl");
}
///
- ///
+ ///
///
public void CheckArgs()
{
@@ -182,7 +182,7 @@ public partial class ConfigEntity : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -191,7 +191,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -200,7 +200,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -209,7 +209,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -218,7 +218,7 @@ public string FullSanitizedName()
return IExecute("fullSanitizedName");
}
///
- ///
+ ///
///
///
///
@@ -227,7 +227,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -236,7 +236,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -280,7 +280,7 @@ public partial class Entity : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -289,7 +289,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -298,7 +298,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -307,7 +307,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -316,7 +316,7 @@ public string EntityPath()
return IExecute("entityPath");
}
///
- ///
+ ///
///
///
@@ -325,7 +325,7 @@ public string EntityType()
return IExecute("entityType");
}
///
- ///
+ ///
///
///
///
@@ -334,7 +334,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
diff --git a/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
index 523cb3312f..9b36d1be56 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ConsumerGroupCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class ConsumerGroupCommand
#region Static methods
///
- ///
+ ///
///
///
@@ -51,7 +51,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -60,7 +60,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
@@ -69,7 +69,7 @@ public static string MISSING_COLUMN_VALUE()
return SExecute(LocalBridgeClazz, "MISSING_COLUMN_VALUE");
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -77,7 +77,7 @@ public static void Main(string[] args)
SExecute(LocalBridgeClazz, "main", new object[] { args });
}
///
- ///
+ ///
///
///
public static void Run(Kafka.Admin.ConsumerGroupCommand.ConsumerGroupCommandOptions opts)
@@ -97,7 +97,7 @@ public partial class ConsumerGroupCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public ConsumerGroupCommandOptions(string[] args)
@@ -121,7 +121,7 @@ public ConsumerGroupCommandOptions(string[] args)
#region Instance methods
///
- ///
+ ///
///
///
@@ -130,7 +130,7 @@ public string AllGroupsDoc()
return IExecute("AllGroupsDoc");
}
///
- ///
+ ///
///
///
@@ -139,7 +139,7 @@ public string AllTopicsDoc()
return IExecute("AllTopicsDoc");
}
///
- ///
+ ///
///
///
@@ -148,7 +148,7 @@ public string BootstrapServerDoc()
return IExecute("BootstrapServerDoc");
}
///
- ///
+ ///
///
///
@@ -157,7 +157,7 @@ public string CommandConfigDoc()
return IExecute("CommandConfigDoc");
}
///
- ///
+ ///
///
///
@@ -166,7 +166,7 @@ public string DeleteDoc()
return IExecute("DeleteDoc");
}
///
- ///
+ ///
///
///
@@ -175,7 +175,7 @@ public string DeleteOffsetsDoc()
return IExecute("DeleteOffsetsDoc");
}
///
- ///
+ ///
///
///
@@ -184,7 +184,7 @@ public string DescribeDoc()
return IExecute("DescribeDoc");
}
///
- ///
+ ///
///
///
@@ -193,7 +193,7 @@ public string DryRunDoc()
return IExecute("DryRunDoc");
}
///
- ///
+ ///
///
///
@@ -202,7 +202,7 @@ public string ExecuteDoc()
return IExecute("ExecuteDoc");
}
///
- ///
+ ///
///
///
@@ -211,7 +211,7 @@ public string ExportDoc()
return IExecute("ExportDoc");
}
///
- ///
+ ///
///
///
@@ -220,7 +220,7 @@ public string GroupDoc()
return IExecute("GroupDoc");
}
///
- ///
+ ///
///
///
@@ -229,7 +229,7 @@ public string ListDoc()
return IExecute("ListDoc");
}
///
- ///
+ ///
///
///
@@ -238,7 +238,7 @@ public string MembersDoc()
return IExecute("MembersDoc");
}
///
- ///
+ ///
///
///
@@ -247,7 +247,7 @@ public string Nl()
return IExecute("nl");
}
///
- ///
+ ///
///
///
@@ -256,7 +256,7 @@ public string OffsetsDoc()
return IExecute("OffsetsDoc");
}
///
- ///
+ ///
///
///
@@ -265,7 +265,7 @@ public string ResetByDurationDoc()
return IExecute("ResetByDurationDoc");
}
///
- ///
+ ///
///
///
@@ -274,7 +274,7 @@ public string ResetFromFileDoc()
return IExecute("ResetFromFileDoc");
}
///
- ///
+ ///
///
///
@@ -283,7 +283,7 @@ public string ResetOffsetsDoc()
return IExecute("ResetOffsetsDoc");
}
///
- ///
+ ///
///
///
@@ -292,7 +292,7 @@ public string ResetShiftByDoc()
return IExecute("ResetShiftByDoc");
}
///
- ///
+ ///
///
///
@@ -301,7 +301,7 @@ public string ResetToCurrentDoc()
return IExecute("ResetToCurrentDoc");
}
///
- ///
+ ///
///
///
@@ -310,7 +310,7 @@ public string ResetToDatetimeDoc()
return IExecute("ResetToDatetimeDoc");
}
///
- ///
+ ///
///
///
@@ -319,7 +319,7 @@ public string ResetToEarliestDoc()
return IExecute("ResetToEarliestDoc");
}
///
- ///
+ ///
///
///
@@ -328,7 +328,7 @@ public string ResetToLatestDoc()
return IExecute("ResetToLatestDoc");
}
///
- ///
+ ///
///
///
@@ -337,7 +337,7 @@ public string ResetToOffsetDoc()
return IExecute("ResetToOffsetDoc");
}
///
- ///
+ ///
///
///
@@ -346,7 +346,7 @@ public string StateDoc()
return IExecute("StateDoc");
}
///
- ///
+ ///
///
///
@@ -355,7 +355,7 @@ public string TimeoutMsDoc()
return IExecute("TimeoutMsDoc");
}
///
- ///
+ ///
///
///
@@ -364,7 +364,7 @@ public string TopicDoc()
return IExecute("TopicDoc");
}
///
- ///
+ ///
///
///
@@ -373,7 +373,7 @@ public string VerboseDoc()
return IExecute("VerboseDoc");
}
///
- ///
+ ///
///
public void CheckArgs()
{
@@ -411,7 +411,7 @@ public partial class ConsumerGroupService
#region Instance methods
///
- ///
+ ///
///
///
@@ -420,7 +420,7 @@ public Kafka.Admin.ConsumerGroupCommand.ConsumerGroupCommandOptions Opts()
return IExecute("opts");
}
///
- ///
+ ///
///
///
///
@@ -429,28 +429,28 @@ public Kafka.Admin.ConsumerGroupCommand.GroupState CollectGroupState(string grou
return IExecute("collectGroupState", groupId);
}
///
- ///
+ ///
///
public void Close()
{
IExecute("close");
}
///
- ///
+ ///
///
public void DeleteOffsets()
{
IExecute("deleteOffsets");
}
///
- ///
+ ///
///
public void DescribeGroups()
{
IExecute("describeGroups");
}
///
- ///
+ ///
///
public void ListGroups()
{
@@ -503,7 +503,7 @@ public partial class CsvRecordNoGroup : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -533,7 +533,7 @@ public CsvRecordNoGroup(string topic, int partition, long offset)
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -542,7 +542,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -551,7 +551,7 @@ public int Partition()
return IExecute("partition");
}
///
- ///
+ ///
///
///
@@ -560,7 +560,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -569,7 +569,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -578,7 +578,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -587,7 +587,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -596,7 +596,7 @@ public string Topic()
return IExecute("topic");
}
///
- ///
+ ///
///
///
///
@@ -607,7 +607,7 @@ public Kafka.Admin.ConsumerGroupCommand.CsvRecordNoGroup Copy(string topic, int
return IExecute("copy", topic, partition, offset);
}
///
- ///
+ ///
///
///
@@ -631,7 +631,7 @@ public partial class CsvRecordWithGroup : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -662,7 +662,7 @@ public CsvRecordWithGroup(string group, string topic, int partition, long offset
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -671,7 +671,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -680,7 +680,7 @@ public int Partition()
return IExecute("partition");
}
///
- ///
+ ///
///
///
@@ -689,7 +689,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -698,7 +698,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -707,7 +707,7 @@ public string Group()
return IExecute("group");
}
///
- ///
+ ///
///
///
///
@@ -716,7 +716,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -725,7 +725,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -734,7 +734,7 @@ public string Topic()
return IExecute("topic");
}
///
- ///
+ ///
///
///
///
@@ -746,7 +746,7 @@ public Kafka.Admin.ConsumerGroupCommand.CsvRecordWithGroup Copy(string group, st
return IExecute("copy", group, topic, partition, offset);
}
///
- ///
+ ///
///
///
@@ -790,7 +790,7 @@ public partial class CsvUtils : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -799,7 +799,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -808,7 +808,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -817,7 +817,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -826,7 +826,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -835,7 +835,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -859,7 +859,7 @@ public partial class GroupState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -891,7 +891,7 @@ public GroupState(string group, Org.Apache.Kafka.Common.Node coordinator, string
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -900,7 +900,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -909,7 +909,7 @@ public int NumMembers()
return IExecute("numMembers");
}
///
- ///
+ ///
///
///
@@ -918,7 +918,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -927,7 +927,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -936,7 +936,7 @@ public string AssignmentStrategy()
return IExecute("assignmentStrategy");
}
///
- ///
+ ///
///
///
@@ -945,7 +945,7 @@ public string Group()
return IExecute("group");
}
///
- ///
+ ///
///
///
///
@@ -954,7 +954,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -963,7 +963,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -972,7 +972,7 @@ public string State()
return IExecute("state");
}
///
- ///
+ ///
///
///
///
@@ -985,7 +985,7 @@ public Kafka.Admin.ConsumerGroupCommand.GroupState Copy(string group, Org.Apache
return IExecute("copy", group, coordinator, assignmentStrategy, state, numMembers);
}
///
- ///
+ ///
///
///
@@ -1060,7 +1060,7 @@ public partial class MemberAssignmentState : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -1069,7 +1069,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -1078,7 +1078,7 @@ public int NumPartitions()
return IExecute("numPartitions");
}
///
- ///
+ ///
///
///
@@ -1087,7 +1087,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -1096,7 +1096,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -1105,7 +1105,7 @@ public string ClientId()
return IExecute("clientId");
}
///
- ///
+ ///
///
///
@@ -1114,7 +1114,7 @@ public string ConsumerId()
return IExecute("consumerId");
}
///
- ///
+ ///
///
///
@@ -1123,7 +1123,7 @@ public string Group()
return IExecute("group");
}
///
- ///
+ ///
///
///
@@ -1132,7 +1132,7 @@ public string GroupInstanceId()
return IExecute("groupInstanceId");
}
///
- ///
+ ///
///
///
@@ -1141,7 +1141,7 @@ public string Host()
return IExecute("host");
}
///
- ///
+ ///
///
///
///
@@ -1150,7 +1150,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -1194,7 +1194,7 @@ public partial class PartitionAssignmentState : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -1203,7 +1203,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -1212,7 +1212,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -1221,7 +1221,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -1230,7 +1230,7 @@ public string Group()
return IExecute("group");
}
///
- ///
+ ///
///
///
///
@@ -1239,7 +1239,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
diff --git a/src/net/KNet/Generated/Kafka/Admin/DeleteRecordsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/DeleteRecordsCommand.cs
deleted file mode 100644
index 8b9f96c9b2..0000000000
--- a/src/net/KNet/Generated/Kafka/Admin/DeleteRecordsCommand.cs
+++ /dev/null
@@ -1,141 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-/*
-* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
-*/
-
-using MASES.JCOBridge.C2JBridge;
-
-namespace Kafka.Admin
-{
- #region DeleteRecordsCommand
- public partial class DeleteRecordsCommand
- {
- #region Constructors
-
- #endregion
-
- #region Class/Interface conversion operators
-
- #endregion
-
- #region Fields
-
- #endregion
-
- #region Static methods
- ///
- ///
- ///
- ///
- ///
- public static void Execute(string[] args, Java.Io.PrintStream _out)
- {
- SExecute(LocalBridgeClazz, "execute", args, _out);
- }
- ///
- ///
- ///
- ///
- public static void Main(string[] args)
- {
- SExecute(LocalBridgeClazz, "main", new object[] { args });
- }
-
- #endregion
-
- #region Instance methods
-
- #endregion
-
- #region Nested classes
- #region DeleteRecordsCommandOptions
- public partial class DeleteRecordsCommandOptions
- {
- #region Constructors
- ///
- ///
- ///
- ///
- public DeleteRecordsCommandOptions(string[] args)
- : base(args)
- {
- }
-
- #endregion
-
- #region Class/Interface conversion operators
-
- #endregion
-
- #region Fields
-
- #endregion
-
- #region Static methods
-
- #endregion
-
- #region Instance methods
- ///
- ///
- ///
-
- ///
- public string BootstrapServerDoc()
- {
- return IExecute("BootstrapServerDoc");
- }
- ///
- ///
- ///
-
- ///
- public string CommandConfigDoc()
- {
- return IExecute("CommandConfigDoc");
- }
- ///
- ///
- ///
-
- ///
- public string OffsetJsonFileDoc()
- {
- return IExecute("offsetJsonFileDoc");
- }
-
- #endregion
-
- #region Nested classes
-
- #endregion
-
- // TODO: complete the class
- }
- #endregion
-
-
- #endregion
-
- // TODO: complete the class
- }
- #endregion
-}
\ No newline at end of file
diff --git a/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs b/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
index e7978b3a0f..c6bb9d3774 100644
--- a/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class FeatureCommand
#region Static methods
///
- ///
+ ///
///
///
///
@@ -52,7 +52,7 @@ public static int MainNoExit(string[] args, Java.Io.PrintStream _out)
return SExecute(LocalBridgeClazz, "mainNoExit", args, _out);
}
///
- ///
+ ///
///
///
///
@@ -62,7 +62,7 @@ public static string LevelToString(string feature, short level)
return SExecute(LocalBridgeClazz, "levelToString", feature, level);
}
///
- ///
+ ///
///
///
///
@@ -71,7 +71,7 @@ public static void HandleDescribe(Java.Io.PrintStream _out, Org.Apache.Kafka.Cli
SExecute(LocalBridgeClazz, "handleDescribe", _out, admin);
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -79,7 +79,7 @@ public static void Main(string[] args)
SExecute(LocalBridgeClazz, "main", new object[] { args });
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommand.cs b/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommand.cs
index aa10c37dcc..3057a4a494 100644
--- a/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class LeaderElectionCommand
#region Static methods
///
- ///
+ ///
///
///
@@ -51,7 +51,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -60,7 +60,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
diff --git a/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommandOptions.cs b/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommandOptions.cs
index f9ecc0c2c5..b02a5ac2a2 100644
--- a/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommandOptions.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/LeaderElectionCommandOptions.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -30,7 +30,7 @@ public partial class LeaderElectionCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public LeaderElectionCommandOptions(string[] args)
diff --git a/src/net/KNet/Generated/Kafka/Admin/LogDirsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/LogDirsCommand.cs
deleted file mode 100644
index 9e69faae0b..0000000000
--- a/src/net/KNet/Generated/Kafka/Admin/LogDirsCommand.cs
+++ /dev/null
@@ -1,114 +0,0 @@
-/*
-* Copyright 2023 MASES s.r.l.
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-* Refer to LICENSE for more information.
-*/
-
-/*
-* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
-*/
-
-using MASES.JCOBridge.C2JBridge;
-
-namespace Kafka.Admin
-{
- #region LogDirsCommand
- public partial class LogDirsCommand
- {
- #region Constructors
-
- #endregion
-
- #region Class/Interface conversion operators
-
- #endregion
-
- #region Fields
-
- #endregion
-
- #region Static methods
- ///
- ///
- ///
- ///
- ///
- public static void Describe(string[] args, Java.Io.PrintStream _out)
- {
- SExecute(LocalBridgeClazz, "describe", args, _out);
- }
- ///
- ///
- ///
- ///
- public static void Main(string[] args)
- {
- SExecute(LocalBridgeClazz, "main", new object[] { args });
- }
-
- #endregion
-
- #region Instance methods
-
- #endregion
-
- #region Nested classes
- #region LogDirsCommandOptions
- public partial class LogDirsCommandOptions
- {
- #region Constructors
- ///
- ///
- ///
- ///
- public LogDirsCommandOptions(string[] args)
- : base(args)
- {
- }
-
- #endregion
-
- #region Class/Interface conversion operators
-
- #endregion
-
- #region Fields
-
- #endregion
-
- #region Static methods
-
- #endregion
-
- #region Instance methods
-
- #endregion
-
- #region Nested classes
-
- #endregion
-
- // TODO: complete the class
- }
- #endregion
-
-
- #endregion
-
- // TODO: complete the class
- }
- #endregion
-}
\ No newline at end of file
diff --git a/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs b/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
index 67735ccdff..4c4169acb8 100644
--- a/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
diff --git a/src/net/KNet/Generated/Kafka/Admin/ReassignPartitionsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ReassignPartitionsCommand.cs
index baebc44ace..1dd6f46fb8 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ReassignPartitionsCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ReassignPartitionsCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class ReassignPartitionsCommand
#region Static methods
///
- ///
+ ///
///
///
///
@@ -52,7 +52,7 @@ public static bool CompareTopicPartitionReplicas(Org.Apache.Kafka.Common.TopicPa
return SExecute(LocalBridgeClazz, "compareTopicPartitionReplicas", a, b);
}
///
- ///
+ ///
///
///
///
@@ -62,7 +62,7 @@ public static bool CompareTopicPartitions(Org.Apache.Kafka.Common.TopicPartition
return SExecute(LocalBridgeClazz, "compareTopicPartitions", a, b);
}
///
- ///
+ ///
///
///
@@ -71,7 +71,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -80,7 +80,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
///
@@ -89,7 +89,7 @@ public static string CurReassignmentsToString(Org.Apache.Kafka.Clients.Admin.Adm
return SExecute(LocalBridgeClazz, "curReassignmentsToString", adminClient);
}
///
- ///
+ ///
///
///
@@ -98,7 +98,7 @@ public static string HelpText()
return SExecute(LocalBridgeClazz, "helpText");
}
///
- ///
+ ///
///
///
///
@@ -107,7 +107,7 @@ public static Kafka.Admin.ReassignPartitionsCommand.ReassignPartitionsCommandOpt
return SExecute(LocalBridgeClazz, "validateAndParseArgs", new object[] { args });
}
///
- ///
+ ///
///
///
///
@@ -118,7 +118,7 @@ public static Kafka.Admin.ReassignPartitionsCommand.VerifyAssignmentResult Verif
return SExecute(LocalBridgeClazz, "verifyAssignment", adminClient, jsonString, preserveThrottles);
}
///
- ///
+ ///
///
///
///
@@ -132,7 +132,7 @@ public static void ExecuteAssignment(Org.Apache.Kafka.Clients.Admin.Admin adminC
SExecute(LocalBridgeClazz, "executeAssignment", adminClient, additional, reassignmentJson, interBrokerThrottle, logDirThrottle, timeoutMs, time);
}
///
- ///
+ ///
///
///
public static void ListReassignments(Org.Apache.Kafka.Clients.Admin.Admin adminClient)
@@ -140,7 +140,7 @@ public static void ListReassignments(Org.Apache.Kafka.Clients.Admin.Admin adminC
SExecute(LocalBridgeClazz, "listReassignments", adminClient);
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -160,7 +160,7 @@ public partial class ActiveMoveState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -190,7 +190,7 @@ public ActiveMoveState(string currentLogDir, string targetLogDir, string futureL
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -199,7 +199,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -208,7 +208,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -217,7 +217,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -226,7 +226,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -235,7 +235,7 @@ public string CurrentLogDir()
return IExecute("currentLogDir");
}
///
- ///
+ ///
///
///
@@ -244,7 +244,7 @@ public string FutureLogDir()
return IExecute("futureLogDir");
}
///
- ///
+ ///
///
///
///
@@ -253,7 +253,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -262,7 +262,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -271,7 +271,7 @@ public string TargetLogDir()
return IExecute("targetLogDir");
}
///
- ///
+ ///
///
///
///
@@ -297,7 +297,7 @@ public partial class CancelledMoveState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -326,7 +326,7 @@ public CancelledMoveState(string currentLogDir, string targetLogDir)
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -335,7 +335,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -344,7 +344,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -353,7 +353,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -362,7 +362,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
@@ -371,7 +371,7 @@ public string CurrentLogDir()
return IExecute("currentLogDir");
}
///
- ///
+ ///
///
///
///
@@ -380,7 +380,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -389,7 +389,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -398,7 +398,7 @@ public string TargetLogDir()
return IExecute("targetLogDir");
}
///
- ///
+ ///
///
///
///
@@ -423,7 +423,7 @@ public partial class CompletedMoveState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
public CompletedMoveState(string targetLogDir)
@@ -451,7 +451,7 @@ public CompletedMoveState(string targetLogDir)
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -460,7 +460,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -469,7 +469,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -478,7 +478,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -487,7 +487,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -496,7 +496,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -505,7 +505,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -514,7 +514,7 @@ public string TargetLogDir()
return IExecute("targetLogDir");
}
///
- ///
+ ///
///
///
///
@@ -554,7 +554,7 @@ public partial class LogDirMoveState
#region Instance methods
///
- ///
+ ///
///
///
@@ -578,7 +578,7 @@ public partial class MissingLogDirMoveState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
public MissingLogDirMoveState(string targetLogDir)
@@ -606,7 +606,7 @@ public MissingLogDirMoveState(string targetLogDir)
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -615,7 +615,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -624,7 +624,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -633,7 +633,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -642,7 +642,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -651,7 +651,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -660,7 +660,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -669,7 +669,7 @@ public string TargetLogDir()
return IExecute("targetLogDir");
}
///
- ///
+ ///
///
///
///
@@ -693,7 +693,7 @@ public partial class MissingReplicaMoveState : Java.Io.ISerializable
{
#region Constructors
///
- ///
+ ///
///
///
public MissingReplicaMoveState(string targetLogDir)
@@ -721,7 +721,7 @@ public MissingReplicaMoveState(string targetLogDir)
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -730,7 +730,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -739,7 +739,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -748,7 +748,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -757,7 +757,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -766,7 +766,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -775,7 +775,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -784,7 +784,7 @@ public string TargetLogDir()
return IExecute("targetLogDir");
}
///
- ///
+ ///
///
///
///
@@ -828,7 +828,7 @@ public partial class PartitionMove : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -837,7 +837,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -846,7 +846,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -855,7 +855,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -864,7 +864,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -908,7 +908,7 @@ public partial class PartitionReassignmentState : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -917,7 +917,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -926,7 +926,7 @@ public bool Done()
return IExecute("done");
}
///
- ///
+ ///
///
///
@@ -935,7 +935,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -944,7 +944,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -953,7 +953,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -977,7 +977,7 @@ public partial class ReassignPartitionsCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public ReassignPartitionsCommandOptions(string[] args)
@@ -1067,7 +1067,7 @@ public partial class VerifyAssignmentResult : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -1076,7 +1076,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -1085,7 +1085,7 @@ public bool MovesOngoing()
return IExecute("movesOngoing");
}
///
- ///
+ ///
///
///
@@ -1094,7 +1094,7 @@ public bool PartsOngoing()
return IExecute("partsOngoing");
}
///
- ///
+ ///
///
///
@@ -1103,7 +1103,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -1112,7 +1112,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -1121,7 +1121,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
diff --git a/src/net/KNet/Generated/Kafka/Admin/TopicCommand.cs b/src/net/KNet/Generated/Kafka/Admin/TopicCommand.cs
index 80bf63f70f..94aba201eb 100644
--- a/src/net/KNet/Generated/Kafka/Admin/TopicCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/TopicCommand.cs
@@ -18,7 +18,7 @@
/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
-* using kafka_2.13-3.5.1.jar as reference
+* using kafka_2.13-3.6.0.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -42,7 +42,7 @@ public partial class TopicCommand
#region Static methods
///
- ///
+ ///
///
///
@@ -51,7 +51,7 @@ public static bool IsDebugEnabled()
return SExecute(LocalBridgeClazz, "isDebugEnabled");
}
///
- ///
+ ///
///
///
@@ -60,7 +60,7 @@ public static bool IsTraceEnabled()
return SExecute(LocalBridgeClazz, "isTraceEnabled");
}
///
- ///
+ ///
///
///
///
@@ -69,7 +69,7 @@ public static Java.Util.Properties ParseTopicConfigsToBeAdded(Kafka.Admin.TopicC
return SExecute(LocalBridgeClazz, "parseTopicConfigsToBeAdded", opts);
}
///
- ///
+ ///
///
///
public static void Main(string[] args)
@@ -89,7 +89,7 @@ public partial class CommandTopicPartition
{
#region Constructors
///
- ///
+ ///
///
///
public CommandTopicPartition(Kafka.Admin.TopicCommand.TopicCommandOptions opts)
@@ -113,7 +113,7 @@ public CommandTopicPartition(Kafka.Admin.TopicCommand.TopicCommandOptions opts)
#region Instance methods
///
- ///
+ ///
///
///
@@ -122,7 +122,7 @@ public bool HasReplicaAssignment()
return IExecute("hasReplicaAssignment");
}
///
- ///
+ ///
///
///
@@ -131,7 +131,7 @@ public bool IfTopicDoesntExist()
return IExecute("ifTopicDoesntExist");
}
///
- ///
+ ///
///
///
@@ -140,7 +140,7 @@ public string Name()
return IExecute("name");
}
///
- ///
+ ///
///
///
@@ -180,7 +180,7 @@ public partial class DescribeOptions
#region Instance methods
///
- ///
+ ///
///
///
@@ -189,7 +189,7 @@ public bool DescribeConfigs()
return IExecute("describeConfigs");
}
///
- ///
+ ///
///
///
@@ -198,7 +198,7 @@ public bool DescribePartitions()
return IExecute("describePartitions");
}
///
- ///
+ ///
///
///
public void MaybePrintPartitionDescription(Kafka.Admin.TopicCommand.PartitionDescription desc)
@@ -241,7 +241,7 @@ public partial class PartitionDescription : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -250,7 +250,7 @@ public bool CanEqual(object x_1)
return IExecute("canEqual", x_1);
}
///
- ///
+ ///
///
///
@@ -259,7 +259,7 @@ public bool IsAtMinIsrPartitions()
return IExecute("isAtMinIsrPartitions");
}
///
- ///
+ ///
///
///
@@ -268,7 +268,7 @@ public bool IsUnderMinIsr()
return IExecute("isUnderMinIsr");
}
///
- ///
+ ///
///
///
@@ -277,7 +277,7 @@ public bool IsUnderReplicated()
return IExecute("isUnderReplicated");
}
///
- ///
+ ///
///
///
@@ -286,7 +286,7 @@ public bool MarkedForDeletion()
return IExecute("markedForDeletion");
}
///
- ///
+ ///
///
///
@@ -295,7 +295,7 @@ public int ProductArity()
return IExecute("productArity");
}
///
- ///
+ ///
///
///
///
@@ -304,7 +304,7 @@ public object ProductElement(int x_1)
return IExecute("productElement", x_1);
}
///
- ///
+ ///
///
///
///
@@ -313,7 +313,7 @@ public string ProductElementName(int x_1)
return IExecute("productElementName", x_1);
}
///
- ///
+ ///
///
///
@@ -322,7 +322,7 @@ public string ProductPrefix()
return IExecute("productPrefix");
}
///
- ///
+ ///
///
///
@@ -331,7 +331,7 @@ public string Topic()
return IExecute("topic");
}
///
- ///
+ ///
///
///
@@ -340,7 +340,7 @@ public Org.Apache.Kafka.Common.TopicPartitionInfo Info()
return IExecute("info");
}
///
- ///
+ ///
///
public void PrintDescription()
{
@@ -362,7 +362,7 @@ public partial class TopicCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public TopicCommandOptions(string[] args)
@@ -386,7 +386,7 @@ public TopicCommandOptions(string[] args)
#region Instance methods
///
- ///
+ ///
///
///
@@ -395,7 +395,7 @@ public bool ExcludeInternalTopics()
return IExecute("excludeInternalTopics");
}
///
- ///
+ ///
///
///
@@ -404,7 +404,7 @@ public bool HasAlterOption()
return IExecute("hasAlterOption");
}
///
- ///
+ ///
///
///
@@ -413,7 +413,7 @@ public bool HasCreateOption()
return IExecute("hasCreateOption");
}
///
- ///
+ ///
///
///
@@ -422,7 +422,7 @@ public bool HasDeleteOption()
return IExecute("hasDeleteOption");
}
///
- ///
+ ///
///
///
@@ -431,7 +431,7 @@ public bool HasDescribeOption()
return IExecute("hasDescribeOption");
}
///
- ///