diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
index a4bb72e10..9387a6e60 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
index 9748bcd86..e520b8249 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
index e33befda4..e14e3627c 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
index b804cebbb..36082e7a6 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.consumer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
index e96efeed2..9be120696 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
index 20df2eaee..4851deab6 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
index bf85e35df..2b0cce27d 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.clients.producer;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
index f653d4631..c16b87192 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
index da0b6ea5f..30aabc3a0 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.config;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
index f99427819..bb09b8667 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.metrics;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
index 0aa10bce2..6cd583d54 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
index 6bf813624..34c19c28e 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serde.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
index 1e70323e9..2a6914136 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.common.serialization;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/RaftClient_Listener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/RaftClient_Listener.java
index 140d2d855..59d3046c2 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/RaftClient_Listener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/raft/RaftClient_Listener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.raft;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
index 386b96b11..ebc84a74a 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaStreams_StateListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaStreams_StateListener.java
index a3fcf8c15..de21fe109 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaStreams_StateListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaStreams_StateListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
index cf767f1df..c7645b551 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.errors;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
index 0a2214184..d490a9040 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
index 8ad373417..26fd22290 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
index 46eef19c7..baef47c50 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
index 22dbc6f3e..151a1bcd5 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
index 8bb71e818..43e4a1bba 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
index f4e43bf9b..2842e0362 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
index 765a1fd4a..2e985338b 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
index 5f432373d..9ce817bd4 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
index 260ea87c1..a2ae3bb8e 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
index 869beebb3..8153c8771 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
index 6f17e3ae6..9fabe9ec4 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
index 6f5b5f208..c5f39ac61 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
index 075a4a5ec..dd65f29b6 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
index 14166287c..b0ddc6f79 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.kstream;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
index d1d0b4303..783f2215d 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
index 5cbe0416a..d8ceb0f24 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/Punctuator.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StandbyUpdateListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StandbyUpdateListener.java
index f2a30253a..79159a1ec 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StandbyUpdateListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StandbyUpdateListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
index b9fe462c9..58ca34c1f 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
index 57d69a912..48a747d42 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
index 99be7a1f8..eb3c75856 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
index 636acd150..1faa2fc4b 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
index 83cd78b65..01df6ec91 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
index dd6a1574a..2d9ed840e 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
diff --git a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
index 646a87d78..1f400896e 100644
--- a/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
+++ b/src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
@@ -17,7 +17,7 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
*/
package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
diff --git a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
index fc01670a7..11829cd23 100644
--- a/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region AclCommand declaration
///
- ///
+ ///
///
public partial class AclCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -68,7 +68,7 @@ public AclCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region AclCommandOptions declaration
///
- ///
+ ///
///
public partial class AclCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -113,7 +113,7 @@ public AclCommandOptions(params object[] args) : base(args) { }
#region AclCommandService declaration
///
- ///
+ ///
///
public partial class AclCommandService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -160,7 +160,7 @@ public AclCommandService(params object[] args) : base(args) { }
#region AuthorizerService declaration
///
- ///
+ ///
///
public partial class AuthorizerService : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -224,7 +224,7 @@ public partial class AclCommand
#region Static methods
///
- ///
+ ///
///
///
public static bool IsDebugEnabled()
@@ -232,7 +232,7 @@ public static bool IsDebugEnabled()
return SExecuteWithSignature(LocalBridgeClazz, "isDebugEnabled", "()Z");
}
///
- ///
+ ///
///
///
public static bool IsTraceEnabled()
@@ -240,7 +240,7 @@ public static bool IsTraceEnabled()
return SExecuteWithSignature(LocalBridgeClazz, "isTraceEnabled", "()Z");
}
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] args)
@@ -260,7 +260,7 @@ public partial class AclCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public AclCommandOptions(Java.Lang.String[] args)
@@ -284,7 +284,7 @@ public AclCommandOptions(Java.Lang.String[] args)
#region Instance methods
///
- ///
+ ///
///
///
public Java.Lang.String CommandConfigDoc()
@@ -292,7 +292,7 @@ public Java.Lang.String CommandConfigDoc()
return IExecuteWithSignature("CommandConfigDoc", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
public void CheckArgs()
{
@@ -330,21 +330,21 @@ public partial class AclCommandService
#region Instance methods
///
- ///
+ ///
///
public void AddAcls()
{
IExecuteWithSignature("addAcls", "()V");
}
///
- ///
+ ///
///
public void ListAcls()
{
IExecuteWithSignature("listAcls", "()V");
}
///
- ///
+ ///
///
public void RemoveAcls()
{
@@ -366,7 +366,7 @@ public partial class AuthorizerService
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -391,7 +391,7 @@ public AuthorizerService(Java.Lang.String authorizerClassName, Kafka.Admin.AclCo
#region Instance methods
///
- ///
+ ///
///
///
public bool IsDebugEnabled()
@@ -399,7 +399,7 @@ public bool IsDebugEnabled()
return IExecuteWithSignature("isDebugEnabled", "()Z");
}
///
- ///
+ ///
///
///
public bool IsTraceEnabled()
@@ -407,7 +407,7 @@ public bool IsTraceEnabled()
return IExecuteWithSignature("isTraceEnabled", "()Z");
}
///
- ///
+ ///
///
///
public Java.Lang.String AuthorizerClassName()
@@ -415,7 +415,7 @@ public Java.Lang.String AuthorizerClassName()
return IExecuteWithSignature("authorizerClassName", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public Java.Lang.String LoggerName()
@@ -423,7 +423,7 @@ public Java.Lang.String LoggerName()
return IExecuteWithSignature("loggerName", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public Java.Lang.String LogIdent()
@@ -431,7 +431,7 @@ public Java.Lang.String LogIdent()
return IExecuteWithSignature("logIdent", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
///
@@ -440,7 +440,7 @@ public Java.Lang.String MsgWithLogIdent(Java.Lang.String msg)
return IExecuteWithSignature("msgWithLogIdent", "(Ljava/lang/String;)Ljava/lang/String;", msg);
}
///
- ///
+ ///
///
///
public Kafka.Admin.AclCommand.AclCommandOptions Opts()
@@ -448,21 +448,21 @@ public Kafka.Admin.AclCommand.AclCommandOptions Opts()
return IExecuteWithSignature("opts", "()Lkafka/admin/AclCommand$AclCommandOptions;");
}
///
- ///
+ ///
///
public void AddAcls()
{
IExecuteWithSignature("addAcls", "()V");
}
///
- ///
+ ///
///
public void ListAcls()
{
IExecuteWithSignature("listAcls", "()V");
}
///
- ///
+ ///
///
public void RemoveAcls()
{
diff --git a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
index c623834a9..e4b42fb8b 100644
--- a/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region BrokerApiVersionsCommand declaration
///
- ///
+ ///
///
public partial class BrokerApiVersionsCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -87,7 +87,7 @@ public partial class BrokerApiVersionsCommand
#region Static methods
///
- ///
+ ///
///
///
///
@@ -96,7 +96,7 @@ public static void Execute(Java.Lang.String[] args, Java.Io.PrintStream _out)
SExecuteWithSignature(LocalBridgeClazz, "execute", "([Ljava/lang/String;Ljava/io/PrintStream;)V", args, _out);
}
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] args)
diff --git a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
index ada78f8b5..bd90190f0 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region ConfigCommand declaration
///
- ///
+ ///
///
public partial class ConfigCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -68,7 +68,7 @@ public ConfigCommand(params object[] args) : base(args) { }
// TODO: complete the class
#region ConfigCommandOptions declaration
///
- ///
+ ///
///
public partial class ConfigCommandOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -113,7 +113,7 @@ public ConfigCommandOptions(params object[] args) : base(args) { }
#region ConfigEntity declaration
///
- ///
+ ///
///
public partial class ConfigEntity : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -158,7 +158,7 @@ public ConfigEntity(params object[] args) : base(args) { }
#region Entity declaration
///
- ///
+ ///
///
public partial class Entity : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -222,7 +222,7 @@ public partial class ConfigCommand
#region Static methods
///
- ///
+ ///
///
///
public static bool IsDebugEnabled()
@@ -230,7 +230,7 @@ public static bool IsDebugEnabled()
return SExecuteWithSignature(LocalBridgeClazz, "isDebugEnabled", "()Z");
}
///
- ///
+ ///
///
///
public static bool IsTraceEnabled()
@@ -238,7 +238,7 @@ public static bool IsTraceEnabled()
return SExecuteWithSignature(LocalBridgeClazz, "isTraceEnabled", "()Z");
}
///
- ///
+ ///
///
///
public static Java.Lang.String BrokerDefaultEntityName()
@@ -246,7 +246,7 @@ public static Java.Lang.String BrokerDefaultEntityName()
return SExecuteWithSignature(LocalBridgeClazz, "BrokerDefaultEntityName", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public static Java.Lang.String BrokerLoggerConfigType()
@@ -254,7 +254,7 @@ public static Java.Lang.String BrokerLoggerConfigType()
return SExecuteWithSignature(LocalBridgeClazz, "BrokerLoggerConfigType", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
///
@@ -263,7 +263,7 @@ public static Java.Util.Properties ParseConfigsToBeAdded(Kafka.Admin.ConfigComma
return SExecuteWithSignature(LocalBridgeClazz, "parseConfigsToBeAdded", "(Lkafka/admin/ConfigCommand$ConfigCommandOptions;)Ljava/util/Properties;", opts);
}
///
- ///
+ ///
///
///
///
@@ -272,7 +272,7 @@ public static Kafka.Admin.ConfigCommand.ConfigEntity ParseEntity(Kafka.Admin.Con
return SExecuteWithSignature(LocalBridgeClazz, "parseEntity", "(Lkafka/admin/ConfigCommand$ConfigCommandOptions;)Lkafka/admin/ConfigCommand$ConfigEntity;", opts);
}
///
- ///
+ ///
///
///
///
@@ -281,7 +281,7 @@ public static void AlterConfig(Org.Apache.Kafka.Clients.Admin.Admin adminClient,
SExecuteWithSignature(LocalBridgeClazz, "alterConfig", "(Lorg/apache/kafka/clients/admin/Admin;Lkafka/admin/ConfigCommand$ConfigCommandOptions;)V", adminClient, opts);
}
///
- ///
+ ///
///
///
///
@@ -290,7 +290,7 @@ public static void DescribeConfig(Org.Apache.Kafka.Clients.Admin.Admin adminClie
SExecuteWithSignature(LocalBridgeClazz, "describeConfig", "(Lorg/apache/kafka/clients/admin/Admin;Lkafka/admin/ConfigCommand$ConfigCommandOptions;)V", adminClient, opts);
}
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] args)
@@ -310,7 +310,7 @@ public partial class ConfigCommandOptions
{
#region Constructors
///
- ///
+ ///
///
///
public ConfigCommandOptions(Java.Lang.String[] args)
@@ -334,7 +334,7 @@ public ConfigCommandOptions(Java.Lang.String[] args)
#region Instance methods
///
- ///
+ ///
///
///
public Java.Lang.String Nl()
@@ -342,7 +342,7 @@ public Java.Lang.String Nl()
return IExecuteWithSignature("nl", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
public void CheckArgs()
{
@@ -384,7 +384,7 @@ public partial class ConfigEntity : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -393,7 +393,7 @@ public bool CanEqual(object x_1)
return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
- ///
+ ///
///
///
public int ProductArity()
@@ -401,7 +401,7 @@ public int ProductArity()
return IExecuteWithSignature("productArity", "()I");
}
///
- ///
+ ///
///
///
///
@@ -410,7 +410,7 @@ public object ProductElement(int x_1)
return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
- ///
+ ///
///
///
public Java.Lang.String FullSanitizedName()
@@ -418,7 +418,7 @@ public Java.Lang.String FullSanitizedName()
return IExecuteWithSignature("fullSanitizedName", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
///
@@ -427,7 +427,7 @@ public Java.Lang.String ProductElementName(int x_1)
return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
- ///
+ ///
///
///
public Java.Lang.String ProductPrefix()
@@ -435,7 +435,7 @@ public Java.Lang.String ProductPrefix()
return IExecuteWithSignature("productPrefix", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public Kafka.Admin.ConfigCommand.Entity Root()
@@ -478,7 +478,7 @@ public partial class Entity : Java.Io.ISerializable
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -487,7 +487,7 @@ public bool CanEqual(object x_1)
return IExecuteWithSignature("canEqual", "(Ljava/lang/Object;)Z", x_1);
}
///
- ///
+ ///
///
///
public int ProductArity()
@@ -495,7 +495,7 @@ public int ProductArity()
return IExecuteWithSignature("productArity", "()I");
}
///
- ///
+ ///
///
///
///
@@ -504,7 +504,7 @@ public object ProductElement(int x_1)
return IExecuteWithSignature("productElement", "(I)Ljava/lang/Object;", x_1);
}
///
- ///
+ ///
///
///
public Java.Lang.String EntityPath()
@@ -512,7 +512,7 @@ public Java.Lang.String EntityPath()
return IExecuteWithSignature("entityPath", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public Java.Lang.String EntityType()
@@ -520,7 +520,7 @@ public Java.Lang.String EntityType()
return IExecuteWithSignature("entityType", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
///
@@ -529,7 +529,7 @@ public Java.Lang.String ProductElementName(int x_1)
return IExecuteWithSignature("productElementName", "(I)Ljava/lang/String;", x_1);
}
///
- ///
+ ///
///
///
public Java.Lang.String ProductPrefix()
diff --git a/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs b/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
index 78082ac34..a51be5e4d 100644
--- a/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/FeatureCommand.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region FeatureCommand declaration
///
- ///
+ ///
///
public partial class FeatureCommand : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -87,7 +87,7 @@ public partial class FeatureCommand
#region Static methods
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] args)
diff --git a/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs b/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
index 97ed5b672..83d525585 100644
--- a/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/RackAwareMode.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region RackAwareMode declaration
///
- ///
+ ///
///
public partial class RackAwareMode : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
diff --git a/src/net/KNet/Generated/Kafka/Admin/ZkSecurityMigrator.cs b/src/net/KNet/Generated/Kafka/Admin/ZkSecurityMigrator.cs
index b0fcd1fd9..b5f072038 100644
--- a/src/net/KNet/Generated/Kafka/Admin/ZkSecurityMigrator.cs
+++ b/src/net/KNet/Generated/Kafka/Admin/ZkSecurityMigrator.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka_2.13-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka_2.13-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Kafka.Admin
{
#region ZkSecurityMigrator declaration
///
- ///
+ ///
///
public partial class ZkSecurityMigrator : MASES.JCOBridge.C2JBridge.JVMBridgeBase, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -87,7 +87,7 @@ public partial class ZkSecurityMigrator
#region Static methods
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] args)
@@ -95,7 +95,7 @@ public static void Main(Java.Lang.String[] args)
SExecuteWithSignature(LocalBridgeClazz, "main", "([Ljava/lang/String;)V", new object[] { args });
}
///
- ///
+ ///
///
///
public static void Run(Java.Lang.String[] args)
@@ -107,7 +107,7 @@ public static void Run(Java.Lang.String[] args)
#region Instance methods
///
- ///
+ ///
///
///
public bool IsDebugEnabled()
@@ -115,7 +115,7 @@ public bool IsDebugEnabled()
return IExecuteWithSignature("isDebugEnabled", "()Z");
}
///
- ///
+ ///
///
///
public bool IsTraceEnabled()
@@ -123,7 +123,7 @@ public bool IsTraceEnabled()
return IExecuteWithSignature("isTraceEnabled", "()Z");
}
///
- ///
+ ///
///
///
public Java.Lang.String LoggerName()
@@ -131,7 +131,7 @@ public Java.Lang.String LoggerName()
return IExecuteWithSignature("loggerName", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
public Java.Lang.String LogIdent()
@@ -139,7 +139,7 @@ public Java.Lang.String LogIdent()
return IExecuteWithSignature("logIdent", "()Ljava/lang/String;");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionOptions.cs
index af7c6ffcc..429e65649 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AbortTransactionOptions declaration
///
- ///
+ ///
///
public partial class AbortTransactionOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionResult.cs
index 9f5478b08..9b13d8383 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AbortTransactionResult declaration
///
- ///
+ ///
///
public partial class AbortTransactionResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -91,7 +91,7 @@ public partial class AbortTransactionResult
#region Instance methods
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionSpec.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionSpec.cs
index 6e973af1d..f4e712f9c 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionSpec.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbortTransactionSpec.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AbortTransactionSpec declaration
///
- ///
+ ///
///
public partial class AbortTransactionSpec : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -75,7 +75,7 @@ public partial class AbortTransactionSpec
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -102,7 +102,7 @@ public AbortTransactionSpec(Org.Apache.Kafka.Common.TopicPartition arg0, long ar
#region Instance methods
///
- ///
+ ///
///
///
public int CoordinatorEpoch()
@@ -110,7 +110,7 @@ public int CoordinatorEpoch()
return IExecuteWithSignature("coordinatorEpoch", "()I");
}
///
- ///
+ ///
///
///
public long ProducerId()
@@ -118,7 +118,7 @@ public long ProducerId()
return IExecuteWithSignature("producerId", "()J");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.TopicPartition TopicPartition()
@@ -126,7 +126,7 @@ public Org.Apache.Kafka.Common.TopicPartition TopicPartition()
return IExecuteWithSignature("topicPartition", "()Lorg/apache/kafka/common/TopicPartition;");
}
///
- ///
+ ///
///
///
public short ProducerEpoch()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbstractOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbstractOptions.cs
index a2171a233..3aa0490bb 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbstractOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AbstractOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AbstractOptions declaration
///
- ///
+ ///
///
public partial class AbstractOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -74,7 +74,7 @@ public AbstractOptions(params object[] args) : base(args) { }
#region AbstractOptions declaration
///
- ///
+ ///
///
///
public partial class AbstractOptions : MASES.JCOBridge.C2JBridge.JVMBridgeBase> where T : Org.Apache.Kafka.Clients.Admin.AbstractOptions
@@ -141,7 +141,7 @@ public partial class AbstractOptions
#region Instance methods
///
- ///
+ ///
///
///
public Java.Lang.Integer TimeoutMs()
@@ -149,7 +149,7 @@ public Java.Lang.Integer TimeoutMs()
return IExecuteWithSignature("timeoutMs", "()Ljava/lang/Integer;");
}
///
- ///
+ ///
///
///
///
@@ -193,7 +193,7 @@ public partial class AbstractOptions
#region Instance methods
///
- ///
+ ///
///
///
public Java.Lang.Integer TimeoutMs()
@@ -201,7 +201,7 @@ public Java.Lang.Integer TimeoutMs()
return IExecuteWithSignature("timeoutMs", "()Ljava/lang/Integer;");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Admin.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Admin.cs
index 6528f0ff6..043af1985 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Admin.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Admin.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region Admin declaration
///
- ///
+ ///
///
public partial class Admin : Java.Lang.AutoCloseable
{
@@ -107,7 +107,7 @@ public partial class Admin : Org.Apache.Kafka.Clients.Admin.IAdmin
#region Static methods
///
- ///
+ ///
///
///
///
@@ -116,7 +116,7 @@ public static Org.Apache.Kafka.Clients.Admin.Admin Create(Java.Util.Map(LocalBridgeClazz, "create", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/Admin;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -129,7 +129,7 @@ public static Org.Apache.Kafka.Clients.Admin.Admin Create(Java.Util.Properties a
#region Instance methods
///
- ///
+ ///
///
///
///
@@ -138,7 +138,7 @@ public static Org.Apache.Kafka.Clients.Admin.Admin Create(Java.Util.Properties a
return IExecuteWithSignature>("metrics", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
///
@@ -148,7 +148,7 @@ public Org.Apache.Kafka.Clients.Admin.AbortTransactionResult AbortTransaction(Or
return IExecuteWithSignature("abortTransaction", "(Lorg/apache/kafka/clients/admin/AbortTransactionSpec;Lorg/apache/kafka/clients/admin/AbortTransactionOptions;)Lorg/apache/kafka/clients/admin/AbortTransactionResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -158,7 +158,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterClientQuotasResult AlterClientQuotas(
return IExecuteWithSignature("alterClientQuotas", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/AlterClientQuotasOptions;)Lorg/apache/kafka/clients/admin/AlterClientQuotasResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -168,7 +168,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterConfigsResult IncrementalAlterConfigs
return IExecuteWithSignature("incrementalAlterConfigs", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/AlterConfigsOptions;)Lorg/apache/kafka/clients/admin/AlterConfigsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -179,7 +179,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterConsumerGroupOffsetsResult AlterConsu
return IExecuteWithSignature("alterConsumerGroupOffsets", "(Ljava/lang/String;Ljava/util/Map;Lorg/apache/kafka/clients/admin/AlterConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult;", arg0, arg1, arg2);
}
///
- ///
+ ///
///
///
///
@@ -189,7 +189,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterPartitionReassignmentsResult AlterPar
return IExecuteWithSignature("alterPartitionReassignments", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/AlterPartitionReassignmentsOptions;)Lorg/apache/kafka/clients/admin/AlterPartitionReassignmentsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -199,7 +199,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterReplicaLogDirsResult AlterReplicaLogD
return IExecuteWithSignature("alterReplicaLogDirs", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/AlterReplicaLogDirsOptions;)Lorg/apache/kafka/clients/admin/AlterReplicaLogDirsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -209,7 +209,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterUserScramCredentialsResult AlterUserS
return IExecuteWithSignature("alterUserScramCredentials", "(Ljava/util/List;Lorg/apache/kafka/clients/admin/AlterUserScramCredentialsOptions;)Lorg/apache/kafka/clients/admin/AlterUserScramCredentialsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -219,7 +219,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateAclsResult CreateAcls(Java.Util.Coll
return IExecuteWithSignature("createAcls", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/CreateAclsOptions;)Lorg/apache/kafka/clients/admin/CreateAclsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -228,7 +228,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateDelegationTokenResult CreateDelegati
return IExecuteWithSignature("createDelegationToken", "(Lorg/apache/kafka/clients/admin/CreateDelegationTokenOptions;)Lorg/apache/kafka/clients/admin/CreateDelegationTokenResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -238,7 +238,7 @@ public Org.Apache.Kafka.Clients.Admin.CreatePartitionsResult CreatePartitions(Ja
return IExecuteWithSignature("createPartitions", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/CreatePartitionsOptions;)Lorg/apache/kafka/clients/admin/CreatePartitionsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -248,7 +248,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateTopicsResult CreateTopics(Java.Util.
return IExecuteWithSignature("createTopics", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/CreateTopicsOptions;)Lorg/apache/kafka/clients/admin/CreateTopicsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -258,7 +258,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteAclsResult DeleteAcls(Java.Util.Coll
return IExecuteWithSignature("deleteAcls", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DeleteAclsOptions;)Lorg/apache/kafka/clients/admin/DeleteAclsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -269,7 +269,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteConsumerGroupOffsetsResult DeleteCon
return IExecuteWithSignature("deleteConsumerGroupOffsets", "(Ljava/lang/String;Ljava/util/Set;Lorg/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult;", arg0, arg1, arg2);
}
///
- ///
+ ///
///
///
///
@@ -279,7 +279,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteConsumerGroupsResult DeleteConsumerG
return IExecuteWithSignature("deleteConsumerGroups", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DeleteConsumerGroupsOptions;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -289,7 +289,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteRecordsResult DeleteRecords(Java.Uti
return IExecuteWithSignature("deleteRecords", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/DeleteRecordsOptions;)Lorg/apache/kafka/clients/admin/DeleteRecordsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -299,7 +299,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteTopicsResult DeleteTopics(Org.Apache
return IExecuteWithSignature("deleteTopics", "(Lorg/apache/kafka/common/TopicCollection;Lorg/apache/kafka/clients/admin/DeleteTopicsOptions;)Lorg/apache/kafka/clients/admin/DeleteTopicsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -309,7 +309,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeAclsResult DescribeAcls(Org.Apache
return IExecuteWithSignature("describeAcls", "(Lorg/apache/kafka/common/acl/AclBindingFilter;Lorg/apache/kafka/clients/admin/DescribeAclsOptions;)Lorg/apache/kafka/clients/admin/DescribeAclsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -319,7 +319,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeClientQuotasResult DescribeClientQ
return IExecuteWithSignature("describeClientQuotas", "(Lorg/apache/kafka/common/quota/ClientQuotaFilter;Lorg/apache/kafka/clients/admin/DescribeClientQuotasOptions;)Lorg/apache/kafka/clients/admin/DescribeClientQuotasResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -328,7 +328,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeClusterResult DescribeCluster(Org.
return IExecuteWithSignature("describeCluster", "(Lorg/apache/kafka/clients/admin/DescribeClusterOptions;)Lorg/apache/kafka/clients/admin/DescribeClusterResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -338,7 +338,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeConfigsResult DescribeConfigs(Java
return IExecuteWithSignature("describeConfigs", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeConfigsOptions;)Lorg/apache/kafka/clients/admin/DescribeConfigsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -348,7 +348,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeConsumerGroupsResult DescribeConsu
return IExecuteWithSignature("describeConsumerGroups", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeConsumerGroupsOptions;)Lorg/apache/kafka/clients/admin/DescribeConsumerGroupsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -357,7 +357,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeDelegationTokenResult DescribeDele
return IExecuteWithSignature("describeDelegationToken", "(Lorg/apache/kafka/clients/admin/DescribeDelegationTokenOptions;)Lorg/apache/kafka/clients/admin/DescribeDelegationTokenResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -366,7 +366,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeFeaturesResult DescribeFeatures(Or
return IExecuteWithSignature("describeFeatures", "(Lorg/apache/kafka/clients/admin/DescribeFeaturesOptions;)Lorg/apache/kafka/clients/admin/DescribeFeaturesResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -376,7 +376,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeLogDirsResult DescribeLogDirs(Java
return IExecuteWithSignature("describeLogDirs", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeLogDirsOptions;)Lorg/apache/kafka/clients/admin/DescribeLogDirsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -385,7 +385,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeMetadataQuorumResult DescribeMetad
return IExecuteWithSignature("describeMetadataQuorum", "(Lorg/apache/kafka/clients/admin/DescribeMetadataQuorumOptions;)Lorg/apache/kafka/clients/admin/DescribeMetadataQuorumResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -395,7 +395,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeProducersResult DescribeProducers(
return IExecuteWithSignature("describeProducers", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeProducersOptions;)Lorg/apache/kafka/clients/admin/DescribeProducersResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -405,7 +405,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeReplicaLogDirsResult DescribeRepli
return IExecuteWithSignature("describeReplicaLogDirs", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeReplicaLogDirsOptions;)Lorg/apache/kafka/clients/admin/DescribeReplicaLogDirsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -415,7 +415,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTopicsResult DescribeTopics(Org.Ap
return IExecuteWithSignature("describeTopics", "(Lorg/apache/kafka/common/TopicCollection;Lorg/apache/kafka/clients/admin/DescribeTopicsOptions;)Lorg/apache/kafka/clients/admin/DescribeTopicsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -425,7 +425,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTransactionsResult DescribeTransac
return IExecuteWithSignature("describeTransactions", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeTransactionsOptions;)Lorg/apache/kafka/clients/admin/DescribeTransactionsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -435,7 +435,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeUserScramCredentialsResult Describ
return IExecuteWithSignature("describeUserScramCredentials", "(Ljava/util/List;Lorg/apache/kafka/clients/admin/DescribeUserScramCredentialsOptions;)Lorg/apache/kafka/clients/admin/DescribeUserScramCredentialsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -446,7 +446,7 @@ public Org.Apache.Kafka.Clients.Admin.ElectLeadersResult ElectLeaders(Org.Apache
return IExecuteWithSignature("electLeaders", "(Lorg/apache/kafka/common/ElectionType;Ljava/util/Set;Lorg/apache/kafka/clients/admin/ElectLeadersOptions;)Lorg/apache/kafka/clients/admin/ElectLeadersResult;", arg0, arg1, arg2);
}
///
- ///
+ ///
///
///
///
@@ -456,7 +456,7 @@ public Org.Apache.Kafka.Clients.Admin.ExpireDelegationTokenResult ExpireDelegati
return IExecuteWithSignature("expireDelegationToken", "([BLorg/apache/kafka/clients/admin/ExpireDelegationTokenOptions;)Lorg/apache/kafka/clients/admin/ExpireDelegationTokenResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -466,7 +466,7 @@ public Org.Apache.Kafka.Clients.Admin.FenceProducersResult FenceProducers(Java.U
return IExecuteWithSignature("fenceProducers", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/FenceProducersOptions;)Lorg/apache/kafka/clients/admin/FenceProducersResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -475,7 +475,7 @@ public Org.Apache.Kafka.Clients.Admin.ListClientMetricsResourcesResult ListClien
return IExecuteWithSignature("listClientMetricsResources", "(Lorg/apache/kafka/clients/admin/ListClientMetricsResourcesOptions;)Lorg/apache/kafka/clients/admin/ListClientMetricsResourcesResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -485,7 +485,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupOffsetsResult ListConsume
return IExecuteWithSignature("listConsumerGroupOffsets", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -494,7 +494,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupsResult ListConsumerGroup
return IExecuteWithSignature("listConsumerGroups", "(Lorg/apache/kafka/clients/admin/ListConsumerGroupsOptions;)Lorg/apache/kafka/clients/admin/ListConsumerGroupsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -504,7 +504,7 @@ public Org.Apache.Kafka.Clients.Admin.ListOffsetsResult ListOffsets(Java.Util.Ma
return IExecuteWithSignature("listOffsets", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/ListOffsetsOptions;)Lorg/apache/kafka/clients/admin/ListOffsetsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -514,7 +514,7 @@ public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListParti
return IExecuteWithSignature("listPartitionReassignments", "(Ljava/util/Optional;Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsOptions;)Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -523,7 +523,7 @@ public Org.Apache.Kafka.Clients.Admin.ListTopicsResult ListTopics(Org.Apache.Kaf
return IExecuteWithSignature("listTopics", "(Lorg/apache/kafka/clients/admin/ListTopicsOptions;)Lorg/apache/kafka/clients/admin/ListTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -532,7 +532,7 @@ public Org.Apache.Kafka.Clients.Admin.ListTransactionsResult ListTransactions(Or
return IExecuteWithSignature("listTransactions", "(Lorg/apache/kafka/clients/admin/ListTransactionsOptions;)Lorg/apache/kafka/clients/admin/ListTransactionsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -542,7 +542,7 @@ public Org.Apache.Kafka.Clients.Admin.RemoveMembersFromConsumerGroupResult Remov
return IExecuteWithSignature("removeMembersFromConsumerGroup", "(Ljava/lang/String;Lorg/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions;)Lorg/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -552,7 +552,7 @@ public Org.Apache.Kafka.Clients.Admin.RenewDelegationTokenResult RenewDelegation
return IExecuteWithSignature("renewDelegationToken", "([BLorg/apache/kafka/clients/admin/RenewDelegationTokenOptions;)Lorg/apache/kafka/clients/admin/RenewDelegationTokenResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -562,7 +562,7 @@ public Org.Apache.Kafka.Clients.Admin.UnregisterBrokerResult UnregisterBroker(in
return IExecuteWithSignature("unregisterBroker", "(ILorg/apache/kafka/clients/admin/UnregisterBrokerOptions;)Lorg/apache/kafka/clients/admin/UnregisterBrokerResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -572,7 +572,7 @@ public Org.Apache.Kafka.Clients.Admin.UpdateFeaturesResult UpdateFeatures(Java.U
return IExecuteWithSignature("updateFeatures", "(Ljava/util/Map;Lorg/apache/kafka/clients/admin/UpdateFeaturesOptions;)Lorg/apache/kafka/clients/admin/UpdateFeaturesResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -581,7 +581,7 @@ public Org.Apache.Kafka.Common.Uuid ClientInstanceId(Java.Time.Duration arg0)
return IExecuteWithSignature("clientInstanceId", "(Ljava/time/Duration;)Lorg/apache/kafka/common/Uuid;", arg0);
}
///
- ///
+ ///
///
///
public void Close(Java.Time.Duration arg0)
@@ -589,7 +589,7 @@ public void Close(Java.Time.Duration arg0)
IExecuteWithSignature("close", "(Ljava/time/Duration;)V", arg0);
}
///
- ///
+ ///
///
///
///
@@ -598,7 +598,7 @@ public Org.Apache.Kafka.Clients.Admin.AbortTransactionResult AbortTransaction(Or
return IExecuteWithSignature("abortTransaction", "(Lorg/apache/kafka/clients/admin/AbortTransactionSpec;)Lorg/apache/kafka/clients/admin/AbortTransactionResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -607,7 +607,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterClientQuotasResult AlterClientQuotas(
return IExecuteWithSignature("alterClientQuotas", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/AlterClientQuotasResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -616,7 +616,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterConfigsResult IncrementalAlterConfigs
return IExecuteWithSignature("incrementalAlterConfigs", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AlterConfigsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -626,7 +626,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterConsumerGroupOffsetsResult AlterConsu
return IExecuteWithSignature("alterConsumerGroupOffsets", "(Ljava/lang/String;Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -635,7 +635,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterPartitionReassignmentsResult AlterPar
return IExecuteWithSignature("alterPartitionReassignments", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AlterPartitionReassignmentsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -644,7 +644,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterReplicaLogDirsResult AlterReplicaLogD
return IExecuteWithSignature("alterReplicaLogDirs", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AlterReplicaLogDirsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -653,7 +653,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterUserScramCredentialsResult AlterUserS
return IExecuteWithSignature("alterUserScramCredentials", "(Ljava/util/List;)Lorg/apache/kafka/clients/admin/AlterUserScramCredentialsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -662,7 +662,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateAclsResult CreateAcls(Java.Util.Coll
return IExecuteWithSignature("createAcls", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/CreateAclsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.CreateDelegationTokenResult CreateDelegationToken()
@@ -670,7 +670,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateDelegationTokenResult CreateDelegati
return IExecuteWithSignature("createDelegationToken", "()Lorg/apache/kafka/clients/admin/CreateDelegationTokenResult;");
}
///
- ///
+ ///
///
///
///
@@ -679,7 +679,7 @@ public Org.Apache.Kafka.Clients.Admin.CreatePartitionsResult CreatePartitions(Ja
return IExecuteWithSignature("createPartitions", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/CreatePartitionsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -688,7 +688,7 @@ public Org.Apache.Kafka.Clients.Admin.CreateTopicsResult CreateTopics(Java.Util.
return IExecuteWithSignature("createTopics", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/CreateTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -697,7 +697,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteAclsResult DeleteAcls(Java.Util.Coll
return IExecuteWithSignature("deleteAcls", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DeleteAclsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -707,7 +707,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteConsumerGroupOffsetsResult DeleteCon
return IExecuteWithSignature("deleteConsumerGroupOffsets", "(Ljava/lang/String;Ljava/util/Set;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -716,7 +716,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteConsumerGroupsResult DeleteConsumerG
return IExecuteWithSignature("deleteConsumerGroups", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -725,7 +725,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteRecordsResult DeleteRecords(Java.Uti
return IExecuteWithSignature("deleteRecords", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/DeleteRecordsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -735,7 +735,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteTopicsResult DeleteTopics(Java.Util.
return IExecuteWithSignature("deleteTopics", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DeleteTopicsOptions;)Lorg/apache/kafka/clients/admin/DeleteTopicsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -744,7 +744,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteTopicsResult DeleteTopics(Java.Util.
return IExecuteWithSignature("deleteTopics", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DeleteTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -753,7 +753,7 @@ public Org.Apache.Kafka.Clients.Admin.DeleteTopicsResult DeleteTopics(Org.Apache
return IExecuteWithSignature("deleteTopics", "(Lorg/apache/kafka/common/TopicCollection;)Lorg/apache/kafka/clients/admin/DeleteTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -762,7 +762,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeAclsResult DescribeAcls(Org.Apache
return IExecuteWithSignature("describeAcls", "(Lorg/apache/kafka/common/acl/AclBindingFilter;)Lorg/apache/kafka/clients/admin/DescribeAclsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -771,7 +771,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeClientQuotasResult DescribeClientQ
return IExecuteWithSignature("describeClientQuotas", "(Lorg/apache/kafka/common/quota/ClientQuotaFilter;)Lorg/apache/kafka/clients/admin/DescribeClientQuotasResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.DescribeClusterResult DescribeCluster()
@@ -779,7 +779,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeClusterResult DescribeCluster()
return IExecuteWithSignature("describeCluster", "()Lorg/apache/kafka/clients/admin/DescribeClusterResult;");
}
///
- ///
+ ///
///
///
///
@@ -788,7 +788,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeConfigsResult DescribeConfigs(Java
return IExecuteWithSignature("describeConfigs", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeConfigsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -797,7 +797,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeConsumerGroupsResult DescribeConsu
return IExecuteWithSignature("describeConsumerGroups", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeConsumerGroupsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.DescribeDelegationTokenResult DescribeDelegationToken()
@@ -805,7 +805,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeDelegationTokenResult DescribeDele
return IExecuteWithSignature("describeDelegationToken", "()Lorg/apache/kafka/clients/admin/DescribeDelegationTokenResult;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.DescribeFeaturesResult DescribeFeatures()
@@ -813,7 +813,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeFeaturesResult DescribeFeatures()
return IExecuteWithSignature("describeFeatures", "()Lorg/apache/kafka/clients/admin/DescribeFeaturesResult;");
}
///
- ///
+ ///
///
///
///
@@ -822,7 +822,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeLogDirsResult DescribeLogDirs(Java
return IExecuteWithSignature("describeLogDirs", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeLogDirsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.DescribeMetadataQuorumResult DescribeMetadataQuorum()
@@ -830,7 +830,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeMetadataQuorumResult DescribeMetad
return IExecuteWithSignature("describeMetadataQuorum", "()Lorg/apache/kafka/clients/admin/DescribeMetadataQuorumResult;");
}
///
- ///
+ ///
///
///
///
@@ -839,7 +839,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeProducersResult DescribeProducers(
return IExecuteWithSignature("describeProducers", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeProducersResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -848,7 +848,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeReplicaLogDirsResult DescribeRepli
return IExecuteWithSignature("describeReplicaLogDirs", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeReplicaLogDirsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -858,7 +858,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTopicsResult DescribeTopics(Java.U
return IExecuteWithSignature("describeTopics", "(Ljava/util/Collection;Lorg/apache/kafka/clients/admin/DescribeTopicsOptions;)Lorg/apache/kafka/clients/admin/DescribeTopicsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -867,7 +867,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTopicsResult DescribeTopics(Java.U
return IExecuteWithSignature("describeTopics", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -876,7 +876,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTopicsResult DescribeTopics(Org.Ap
return IExecuteWithSignature("describeTopics", "(Lorg/apache/kafka/common/TopicCollection;)Lorg/apache/kafka/clients/admin/DescribeTopicsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -885,7 +885,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeTransactionsResult DescribeTransac
return IExecuteWithSignature("describeTransactions", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeTransactionsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.DescribeUserScramCredentialsResult DescribeUserScramCredentials()
@@ -893,7 +893,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeUserScramCredentialsResult Describ
return IExecuteWithSignature("describeUserScramCredentials", "()Lorg/apache/kafka/clients/admin/DescribeUserScramCredentialsResult;");
}
///
- ///
+ ///
///
///
///
@@ -902,7 +902,7 @@ public Org.Apache.Kafka.Clients.Admin.DescribeUserScramCredentialsResult Describ
return IExecuteWithSignature("describeUserScramCredentials", "(Ljava/util/List;)Lorg/apache/kafka/clients/admin/DescribeUserScramCredentialsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -912,7 +912,7 @@ public Org.Apache.Kafka.Clients.Admin.ElectLeadersResult ElectLeaders(Org.Apache
return IExecuteWithSignature("electLeaders", "(Lorg/apache/kafka/common/ElectionType;Ljava/util/Set;)Lorg/apache/kafka/clients/admin/ElectLeadersResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -921,7 +921,7 @@ public Org.Apache.Kafka.Clients.Admin.ExpireDelegationTokenResult ExpireDelegati
return IExecuteWithSignature("expireDelegationToken", "([B)Lorg/apache/kafka/clients/admin/ExpireDelegationTokenResult;", new object[] { arg0 });
}
///
- ///
+ ///
///
///
///
@@ -930,7 +930,7 @@ public Org.Apache.Kafka.Clients.Admin.FenceProducersResult FenceProducers(Java.U
return IExecuteWithSignature("fenceProducers", "(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/FenceProducersResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ListClientMetricsResourcesResult ListClientMetricsResources()
@@ -938,7 +938,7 @@ public Org.Apache.Kafka.Clients.Admin.ListClientMetricsResourcesResult ListClien
return IExecuteWithSignature("listClientMetricsResources", "()Lorg/apache/kafka/clients/admin/ListClientMetricsResourcesResult;");
}
///
- ///
+ ///
///
///
///
@@ -948,7 +948,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupOffsetsResult ListConsume
return IExecuteWithSignature("listConsumerGroupOffsets", "(Ljava/lang/String;Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -957,7 +957,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupOffsetsResult ListConsume
return IExecuteWithSignature("listConsumerGroupOffsets", "(Ljava/lang/String;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -966,7 +966,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupOffsetsResult ListConsume
return IExecuteWithSignature("listConsumerGroupOffsets", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupsResult ListConsumerGroups()
@@ -974,7 +974,7 @@ public Org.Apache.Kafka.Clients.Admin.ListConsumerGroupsResult ListConsumerGroup
return IExecuteWithSignature("listConsumerGroups", "()Lorg/apache/kafka/clients/admin/ListConsumerGroupsResult;");
}
///
- ///
+ ///
///
///
///
@@ -983,7 +983,7 @@ public Org.Apache.Kafka.Clients.Admin.ListOffsetsResult ListOffsets(Java.Util.Ma
return IExecuteWithSignature("listOffsets", "(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/ListOffsetsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListPartitionReassignments()
@@ -991,7 +991,7 @@ public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListParti
return IExecuteWithSignature("listPartitionReassignments", "()Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsResult;");
}
///
- ///
+ ///
///
///
///
@@ -1001,7 +1001,7 @@ public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListParti
return IExecuteWithSignature("listPartitionReassignments", "(Ljava/util/Set;Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsOptions;)Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsResult;", arg0, arg1);
}
///
- ///
+ ///
///
///
///
@@ -1010,7 +1010,7 @@ public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListParti
return IExecuteWithSignature("listPartitionReassignments", "(Ljava/util/Set;)Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsResult;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -1019,7 +1019,7 @@ public Org.Apache.Kafka.Clients.Admin.ListPartitionReassignmentsResult ListParti
return IExecuteWithSignature("listPartitionReassignments", "(Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsOptions;)Lorg/apache/kafka/clients/admin/ListPartitionReassignmentsResult;", arg0);
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ListTopicsResult ListTopics()
@@ -1027,7 +1027,7 @@ public Org.Apache.Kafka.Clients.Admin.ListTopicsResult ListTopics()
return IExecuteWithSignature("listTopics", "()Lorg/apache/kafka/clients/admin/ListTopicsResult;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ListTransactionsResult ListTransactions()
@@ -1035,7 +1035,7 @@ public Org.Apache.Kafka.Clients.Admin.ListTransactionsResult ListTransactions()
return IExecuteWithSignature("listTransactions", "()Lorg/apache/kafka/clients/admin/ListTransactionsResult;");
}
///
- ///
+ ///
///
///
///
@@ -1044,7 +1044,7 @@ public Org.Apache.Kafka.Clients.Admin.RenewDelegationTokenResult RenewDelegation
return IExecuteWithSignature("renewDelegationToken", "([B)Lorg/apache/kafka/clients/admin/RenewDelegationTokenResult;", new object[] { arg0 });
}
///
- ///
+ ///
///
///
///
@@ -1053,7 +1053,7 @@ public Org.Apache.Kafka.Clients.Admin.UnregisterBrokerResult UnregisterBroker(in
return IExecuteWithSignature("unregisterBroker", "(I)Lorg/apache/kafka/clients/admin/UnregisterBrokerResult;", arg0);
}
///
- ///
+ ///
///
public void Close()
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClient.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClient.cs
index 14cfd2b90..2fa99191e 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClient.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClient.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AdminClient declaration
///
- ///
+ ///
///
public partial class AdminClient : Org.Apache.Kafka.Clients.Admin.Admin
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClientConfig.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClientConfig.cs
index b8f7cd2c8..117ee6286 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClientConfig.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AdminClientConfig.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AdminClientConfig declaration
///
- ///
+ ///
///
public partial class AdminClientConfig : Org.Apache.Kafka.Common.Config.AbstractConfig, MASES.JCOBridge.C2JBridge.IJVMBridgeMain
{
@@ -75,7 +75,7 @@ public partial class AdminClientConfig
{
#region Constructors
///
- ///
+ ///
///
///
public AdminClientConfig(Java.Util.Map arg0)
@@ -91,187 +91,187 @@ public AdminClientConfig(Java.Util.Map arg0)
#region Fields
///
- ///
+ ///
///
public static Java.Lang.String AUTO_INCLUDE_JMX_REPORTER_DOC { get { if (!_AUTO_INCLUDE_JMX_REPORTER_DOCReady) { _AUTO_INCLUDE_JMX_REPORTER_DOCContent = SGetField(LocalBridgeClazz, "AUTO_INCLUDE_JMX_REPORTER_DOC"); _AUTO_INCLUDE_JMX_REPORTER_DOCReady = true; } return _AUTO_INCLUDE_JMX_REPORTER_DOCContent; } }
private static Java.Lang.String _AUTO_INCLUDE_JMX_REPORTER_DOCContent = default;
private static bool _AUTO_INCLUDE_JMX_REPORTER_DOCReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String BOOTSTRAP_CONTROLLERS_CONFIG { get { if (!_BOOTSTRAP_CONTROLLERS_CONFIGReady) { _BOOTSTRAP_CONTROLLERS_CONFIGContent = SGetField(LocalBridgeClazz, "BOOTSTRAP_CONTROLLERS_CONFIG"); _BOOTSTRAP_CONTROLLERS_CONFIGReady = true; } return _BOOTSTRAP_CONTROLLERS_CONFIGContent; } }
private static Java.Lang.String _BOOTSTRAP_CONTROLLERS_CONFIGContent = default;
private static bool _BOOTSTRAP_CONTROLLERS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String BOOTSTRAP_CONTROLLERS_DOC { get { if (!_BOOTSTRAP_CONTROLLERS_DOCReady) { _BOOTSTRAP_CONTROLLERS_DOCContent = SGetField(LocalBridgeClazz, "BOOTSTRAP_CONTROLLERS_DOC"); _BOOTSTRAP_CONTROLLERS_DOCReady = true; } return _BOOTSTRAP_CONTROLLERS_DOCContent; } }
private static Java.Lang.String _BOOTSTRAP_CONTROLLERS_DOCContent = default;
private static bool _BOOTSTRAP_CONTROLLERS_DOCReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String BOOTSTRAP_SERVERS_CONFIG { get { if (!_BOOTSTRAP_SERVERS_CONFIGReady) { _BOOTSTRAP_SERVERS_CONFIGContent = SGetField(LocalBridgeClazz, "BOOTSTRAP_SERVERS_CONFIG"); _BOOTSTRAP_SERVERS_CONFIGReady = true; } return _BOOTSTRAP_SERVERS_CONFIGContent; } }
private static Java.Lang.String _BOOTSTRAP_SERVERS_CONFIGContent = default;
private static bool _BOOTSTRAP_SERVERS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String CLIENT_DNS_LOOKUP_CONFIG { get { if (!_CLIENT_DNS_LOOKUP_CONFIGReady) { _CLIENT_DNS_LOOKUP_CONFIGContent = SGetField(LocalBridgeClazz, "CLIENT_DNS_LOOKUP_CONFIG"); _CLIENT_DNS_LOOKUP_CONFIGReady = true; } return _CLIENT_DNS_LOOKUP_CONFIGContent; } }
private static Java.Lang.String _CLIENT_DNS_LOOKUP_CONFIGContent = default;
private static bool _CLIENT_DNS_LOOKUP_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String CLIENT_ID_CONFIG { get { if (!_CLIENT_ID_CONFIGReady) { _CLIENT_ID_CONFIGContent = SGetField(LocalBridgeClazz, "CLIENT_ID_CONFIG"); _CLIENT_ID_CONFIGReady = true; } return _CLIENT_ID_CONFIGContent; } }
private static Java.Lang.String _CLIENT_ID_CONFIGContent = default;
private static bool _CLIENT_ID_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG { get { if (!_CONNECTIONS_MAX_IDLE_MS_CONFIGReady) { _CONNECTIONS_MAX_IDLE_MS_CONFIGContent = SGetField(LocalBridgeClazz, "CONNECTIONS_MAX_IDLE_MS_CONFIG"); _CONNECTIONS_MAX_IDLE_MS_CONFIGReady = true; } return _CONNECTIONS_MAX_IDLE_MS_CONFIGContent; } }
private static Java.Lang.String _CONNECTIONS_MAX_IDLE_MS_CONFIGContent = default;
private static bool _CONNECTIONS_MAX_IDLE_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String DEFAULT_API_TIMEOUT_MS_CONFIG { get { if (!_DEFAULT_API_TIMEOUT_MS_CONFIGReady) { _DEFAULT_API_TIMEOUT_MS_CONFIGContent = SGetField(LocalBridgeClazz, "DEFAULT_API_TIMEOUT_MS_CONFIG"); _DEFAULT_API_TIMEOUT_MS_CONFIGReady = true; } return _DEFAULT_API_TIMEOUT_MS_CONFIGContent; } }
private static Java.Lang.String _DEFAULT_API_TIMEOUT_MS_CONFIGContent = default;
private static bool _DEFAULT_API_TIMEOUT_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String DEFAULT_METADATA_RECOVERY_STRATEGY { get { if (!_DEFAULT_METADATA_RECOVERY_STRATEGYReady) { _DEFAULT_METADATA_RECOVERY_STRATEGYContent = SGetField(LocalBridgeClazz, "DEFAULT_METADATA_RECOVERY_STRATEGY"); _DEFAULT_METADATA_RECOVERY_STRATEGYReady = true; } return _DEFAULT_METADATA_RECOVERY_STRATEGYContent; } }
private static Java.Lang.String _DEFAULT_METADATA_RECOVERY_STRATEGYContent = default;
private static bool _DEFAULT_METADATA_RECOVERY_STRATEGYReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String DEFAULT_SECURITY_PROTOCOL { get { if (!_DEFAULT_SECURITY_PROTOCOLReady) { _DEFAULT_SECURITY_PROTOCOLContent = SGetField(LocalBridgeClazz, "DEFAULT_SECURITY_PROTOCOL"); _DEFAULT_SECURITY_PROTOCOLReady = true; } return _DEFAULT_SECURITY_PROTOCOLContent; } }
private static Java.Lang.String _DEFAULT_SECURITY_PROTOCOLContent = default;
private static bool _DEFAULT_SECURITY_PROTOCOLReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String ENABLE_METRICS_PUSH_CONFIG { get { if (!_ENABLE_METRICS_PUSH_CONFIGReady) { _ENABLE_METRICS_PUSH_CONFIGContent = SGetField(LocalBridgeClazz, "ENABLE_METRICS_PUSH_CONFIG"); _ENABLE_METRICS_PUSH_CONFIGReady = true; } return _ENABLE_METRICS_PUSH_CONFIGContent; } }
private static Java.Lang.String _ENABLE_METRICS_PUSH_CONFIGContent = default;
private static bool _ENABLE_METRICS_PUSH_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String ENABLE_METRICS_PUSH_DOC { get { if (!_ENABLE_METRICS_PUSH_DOCReady) { _ENABLE_METRICS_PUSH_DOCContent = SGetField(LocalBridgeClazz, "ENABLE_METRICS_PUSH_DOC"); _ENABLE_METRICS_PUSH_DOCReady = true; } return _ENABLE_METRICS_PUSH_DOCContent; } }
private static Java.Lang.String _ENABLE_METRICS_PUSH_DOCContent = default;
private static bool _ENABLE_METRICS_PUSH_DOCReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METADATA_MAX_AGE_CONFIG { get { if (!_METADATA_MAX_AGE_CONFIGReady) { _METADATA_MAX_AGE_CONFIGContent = SGetField(LocalBridgeClazz, "METADATA_MAX_AGE_CONFIG"); _METADATA_MAX_AGE_CONFIGReady = true; } return _METADATA_MAX_AGE_CONFIGContent; } }
private static Java.Lang.String _METADATA_MAX_AGE_CONFIGContent = default;
private static bool _METADATA_MAX_AGE_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METADATA_RECOVERY_STRATEGY_CONFIG { get { if (!_METADATA_RECOVERY_STRATEGY_CONFIGReady) { _METADATA_RECOVERY_STRATEGY_CONFIGContent = SGetField(LocalBridgeClazz, "METADATA_RECOVERY_STRATEGY_CONFIG"); _METADATA_RECOVERY_STRATEGY_CONFIGReady = true; } return _METADATA_RECOVERY_STRATEGY_CONFIGContent; } }
private static Java.Lang.String _METADATA_RECOVERY_STRATEGY_CONFIGContent = default;
private static bool _METADATA_RECOVERY_STRATEGY_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METADATA_RECOVERY_STRATEGY_DOC { get { if (!_METADATA_RECOVERY_STRATEGY_DOCReady) { _METADATA_RECOVERY_STRATEGY_DOCContent = SGetField(LocalBridgeClazz, "METADATA_RECOVERY_STRATEGY_DOC"); _METADATA_RECOVERY_STRATEGY_DOCReady = true; } return _METADATA_RECOVERY_STRATEGY_DOCContent; } }
private static Java.Lang.String _METADATA_RECOVERY_STRATEGY_DOCContent = default;
private static bool _METADATA_RECOVERY_STRATEGY_DOCReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METRIC_REPORTER_CLASSES_CONFIG { get { if (!_METRIC_REPORTER_CLASSES_CONFIGReady) { _METRIC_REPORTER_CLASSES_CONFIGContent = SGetField(LocalBridgeClazz, "METRIC_REPORTER_CLASSES_CONFIG"); _METRIC_REPORTER_CLASSES_CONFIGReady = true; } return _METRIC_REPORTER_CLASSES_CONFIGContent; } }
private static Java.Lang.String _METRIC_REPORTER_CLASSES_CONFIGContent = default;
private static bool _METRIC_REPORTER_CLASSES_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METRICS_NUM_SAMPLES_CONFIG { get { if (!_METRICS_NUM_SAMPLES_CONFIGReady) { _METRICS_NUM_SAMPLES_CONFIGContent = SGetField(LocalBridgeClazz, "METRICS_NUM_SAMPLES_CONFIG"); _METRICS_NUM_SAMPLES_CONFIGReady = true; } return _METRICS_NUM_SAMPLES_CONFIGContent; } }
private static Java.Lang.String _METRICS_NUM_SAMPLES_CONFIGContent = default;
private static bool _METRICS_NUM_SAMPLES_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METRICS_RECORDING_LEVEL_CONFIG { get { if (!_METRICS_RECORDING_LEVEL_CONFIGReady) { _METRICS_RECORDING_LEVEL_CONFIGContent = SGetField(LocalBridgeClazz, "METRICS_RECORDING_LEVEL_CONFIG"); _METRICS_RECORDING_LEVEL_CONFIGReady = true; } return _METRICS_RECORDING_LEVEL_CONFIGContent; } }
private static Java.Lang.String _METRICS_RECORDING_LEVEL_CONFIGContent = default;
private static bool _METRICS_RECORDING_LEVEL_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG { get { if (!_METRICS_SAMPLE_WINDOW_MS_CONFIGReady) { _METRICS_SAMPLE_WINDOW_MS_CONFIGContent = SGetField(LocalBridgeClazz, "METRICS_SAMPLE_WINDOW_MS_CONFIG"); _METRICS_SAMPLE_WINDOW_MS_CONFIGReady = true; } return _METRICS_SAMPLE_WINDOW_MS_CONFIGContent; } }
private static Java.Lang.String _METRICS_SAMPLE_WINDOW_MS_CONFIGContent = default;
private static bool _METRICS_SAMPLE_WINDOW_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RECEIVE_BUFFER_CONFIG { get { if (!_RECEIVE_BUFFER_CONFIGReady) { _RECEIVE_BUFFER_CONFIGContent = SGetField(LocalBridgeClazz, "RECEIVE_BUFFER_CONFIG"); _RECEIVE_BUFFER_CONFIGReady = true; } return _RECEIVE_BUFFER_CONFIGContent; } }
private static Java.Lang.String _RECEIVE_BUFFER_CONFIGContent = default;
private static bool _RECEIVE_BUFFER_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG { get { if (!_RECONNECT_BACKOFF_MAX_MS_CONFIGReady) { _RECONNECT_BACKOFF_MAX_MS_CONFIGContent = SGetField(LocalBridgeClazz, "RECONNECT_BACKOFF_MAX_MS_CONFIG"); _RECONNECT_BACKOFF_MAX_MS_CONFIGReady = true; } return _RECONNECT_BACKOFF_MAX_MS_CONFIGContent; } }
private static Java.Lang.String _RECONNECT_BACKOFF_MAX_MS_CONFIGContent = default;
private static bool _RECONNECT_BACKOFF_MAX_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RECONNECT_BACKOFF_MS_CONFIG { get { if (!_RECONNECT_BACKOFF_MS_CONFIGReady) { _RECONNECT_BACKOFF_MS_CONFIGContent = SGetField(LocalBridgeClazz, "RECONNECT_BACKOFF_MS_CONFIG"); _RECONNECT_BACKOFF_MS_CONFIGReady = true; } return _RECONNECT_BACKOFF_MS_CONFIGContent; } }
private static Java.Lang.String _RECONNECT_BACKOFF_MS_CONFIGContent = default;
private static bool _RECONNECT_BACKOFF_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String REQUEST_TIMEOUT_MS_CONFIG { get { if (!_REQUEST_TIMEOUT_MS_CONFIGReady) { _REQUEST_TIMEOUT_MS_CONFIGContent = SGetField(LocalBridgeClazz, "REQUEST_TIMEOUT_MS_CONFIG"); _REQUEST_TIMEOUT_MS_CONFIGReady = true; } return _REQUEST_TIMEOUT_MS_CONFIGContent; } }
private static Java.Lang.String _REQUEST_TIMEOUT_MS_CONFIGContent = default;
private static bool _REQUEST_TIMEOUT_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RETRIES_CONFIG { get { if (!_RETRIES_CONFIGReady) { _RETRIES_CONFIGContent = SGetField(LocalBridgeClazz, "RETRIES_CONFIG"); _RETRIES_CONFIGReady = true; } return _RETRIES_CONFIGContent; } }
private static Java.Lang.String _RETRIES_CONFIGContent = default;
private static bool _RETRIES_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RETRY_BACKOFF_MAX_MS_CONFIG { get { if (!_RETRY_BACKOFF_MAX_MS_CONFIGReady) { _RETRY_BACKOFF_MAX_MS_CONFIGContent = SGetField(LocalBridgeClazz, "RETRY_BACKOFF_MAX_MS_CONFIG"); _RETRY_BACKOFF_MAX_MS_CONFIGReady = true; } return _RETRY_BACKOFF_MAX_MS_CONFIGContent; } }
private static Java.Lang.String _RETRY_BACKOFF_MAX_MS_CONFIGContent = default;
private static bool _RETRY_BACKOFF_MAX_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String RETRY_BACKOFF_MS_CONFIG { get { if (!_RETRY_BACKOFF_MS_CONFIGReady) { _RETRY_BACKOFF_MS_CONFIGContent = SGetField(LocalBridgeClazz, "RETRY_BACKOFF_MS_CONFIG"); _RETRY_BACKOFF_MS_CONFIGReady = true; } return _RETRY_BACKOFF_MS_CONFIGContent; } }
private static Java.Lang.String _RETRY_BACKOFF_MS_CONFIGContent = default;
private static bool _RETRY_BACKOFF_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String SECURITY_PROTOCOL_CONFIG { get { if (!_SECURITY_PROTOCOL_CONFIGReady) { _SECURITY_PROTOCOL_CONFIGContent = SGetField(LocalBridgeClazz, "SECURITY_PROTOCOL_CONFIG"); _SECURITY_PROTOCOL_CONFIGReady = true; } return _SECURITY_PROTOCOL_CONFIGContent; } }
private static Java.Lang.String _SECURITY_PROTOCOL_CONFIGContent = default;
private static bool _SECURITY_PROTOCOL_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String SECURITY_PROVIDERS_CONFIG { get { if (!_SECURITY_PROVIDERS_CONFIGReady) { _SECURITY_PROVIDERS_CONFIGContent = SGetField(LocalBridgeClazz, "SECURITY_PROVIDERS_CONFIG"); _SECURITY_PROVIDERS_CONFIGReady = true; } return _SECURITY_PROVIDERS_CONFIGContent; } }
private static Java.Lang.String _SECURITY_PROVIDERS_CONFIGContent = default;
private static bool _SECURITY_PROVIDERS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String SEND_BUFFER_CONFIG { get { if (!_SEND_BUFFER_CONFIGReady) { _SEND_BUFFER_CONFIGContent = SGetField(LocalBridgeClazz, "SEND_BUFFER_CONFIG"); _SEND_BUFFER_CONFIGReady = true; } return _SEND_BUFFER_CONFIGContent; } }
private static Java.Lang.String _SEND_BUFFER_CONFIGContent = default;
private static bool _SEND_BUFFER_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG { get { if (!_SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGReady) { _SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGContent = SGetField(LocalBridgeClazz, "SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG"); _SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGReady = true; } return _SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGContent; } }
private static Java.Lang.String _SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGContent = default;
private static bool _SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIGReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Java.Lang.String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG { get { if (!_SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIGReady) { _SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIGContent = SGetField(LocalBridgeClazz, "SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG"); _SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIGReady = true; } return _SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIGContent; } }
private static Java.Lang.String _SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIGContent = default;
@@ -281,7 +281,7 @@ public AdminClientConfig(Java.Util.Map arg0)
#region Static methods
///
- ///
+ ///
///
///
public static Java.Util.Set ConfigNames()
@@ -289,7 +289,7 @@ public AdminClientConfig(Java.Util.Map arg0)
return SExecuteWithSignature>(LocalBridgeClazz, "configNames", "()Ljava/util/Set;");
}
///
- ///
+ ///
///
///
public static Org.Apache.Kafka.Common.Config.ConfigDef ConfigDef()
@@ -297,7 +297,7 @@ public static Org.Apache.Kafka.Common.Config.ConfigDef ConfigDef()
return SExecuteWithSignature(LocalBridgeClazz, "configDef", "()Lorg/apache/kafka/common/config/ConfigDef;");
}
///
- ///
+ ///
///
///
public static void Main(Java.Lang.String[] arg0)
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasOptions.cs
index 5092dcc16..a66cc8e94 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterClientQuotasOptions declaration
///
- ///
+ ///
///
public partial class AlterClientQuotasOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
@@ -91,7 +91,7 @@ public partial class AlterClientQuotasOptions
#region Instance methods
///
- ///
+ ///
///
///
public bool ValidateOnly()
@@ -99,7 +99,7 @@ public bool ValidateOnly()
return IExecuteWithSignature("validateOnly", "()Z");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasResult.cs
index 50d03bff7..d20b3f742 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterClientQuotasResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterClientQuotasResult declaration
///
- ///
+ ///
///
public partial class AlterClientQuotasResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -75,7 +75,7 @@ public partial class AlterClientQuotasResult
{
#region Constructors
///
- ///
+ ///
///
///
public AlterClientQuotasResult(Java.Util.Map> arg0)
@@ -99,7 +99,7 @@ public AlterClientQuotasResult(Java.Util.Map
- ///
+ ///
///
///
public Java.Util.Map> Values()
@@ -107,7 +107,7 @@ public AlterClientQuotasResult(Java.Util.Map>>("values", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigOp.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigOp.cs
index 0bcde37c6..38957c7ef 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigOp.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigOp.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterConfigOp declaration
///
- ///
+ ///
///
public partial class AlterConfigOp : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -68,7 +68,7 @@ public AlterConfigOp(params object[] args) : base(args) { }
// TODO: complete the class
#region OpType declaration
///
- ///
+ ///
///
public partial class OpType : Java.Lang.Enum
{
@@ -120,7 +120,7 @@ public partial class AlterConfigOp
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -145,7 +145,7 @@ public AlterConfigOp(Org.Apache.Kafka.Clients.Admin.ConfigEntry arg0, Org.Apache
#region Instance methods
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType OpTypeMethod()
@@ -153,7 +153,7 @@ public Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType OpTypeMethod()
return IExecuteWithSignature("opType", "()Lorg/apache/kafka/clients/admin/AlterConfigOp$OpType;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Clients.Admin.ConfigEntry ConfigEntry()
@@ -177,25 +177,25 @@ public partial class OpType
#region Fields
///
- ///
+ ///
///
public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType APPEND { get { if (!_APPENDReady) { _APPENDContent = SGetField(LocalBridgeClazz, "APPEND"); _APPENDReady = true; } return _APPENDContent; } }
private static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType _APPENDContent = default;
private static bool _APPENDReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType DELETE { get { if (!_DELETEReady) { _DELETEContent = SGetField(LocalBridgeClazz, "DELETE"); _DELETEReady = true; } return _DELETEContent; } }
private static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType _DELETEContent = default;
private static bool _DELETEReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType SET { get { if (!_SETReady) { _SETContent = SGetField(LocalBridgeClazz, "SET"); _SETReady = true; } return _SETContent; } }
private static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType _SETContent = default;
private static bool _SETReady = false; // this is used because in case of generics
///
- ///
+ ///
///
public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType SUBTRACT { get { if (!_SUBTRACTReady) { _SUBTRACTContent = SGetField(LocalBridgeClazz, "SUBTRACT"); _SUBTRACTReady = true; } return _SUBTRACTContent; } }
private static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType _SUBTRACTContent = default;
@@ -205,7 +205,7 @@ public partial class OpType
#region Static methods
///
- ///
+ ///
///
///
///
@@ -214,7 +214,7 @@ public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType ForId(byte arg
return SExecuteWithSignature(LocalBridgeClazz, "forId", "(B)Lorg/apache/kafka/clients/admin/AlterConfigOp$OpType;", arg0);
}
///
- ///
+ ///
///
///
///
@@ -223,7 +223,7 @@ public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType ValueOf(Java.L
return SExecuteWithSignature(LocalBridgeClazz, "valueOf", "(Ljava/lang/String;)Lorg/apache/kafka/clients/admin/AlterConfigOp$OpType;", arg0);
}
///
- ///
+ ///
///
///
public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType[] Values()
@@ -235,7 +235,7 @@ public static Org.Apache.Kafka.Clients.Admin.AlterConfigOp.OpType[] Values()
#region Instance methods
///
- ///
+ ///
///
///
public byte Id()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsOptions.cs
index a4c80cfc5..eb71a1ede 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterConfigsOptions declaration
///
- ///
+ ///
///
public partial class AlterConfigsOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
@@ -91,7 +91,7 @@ public partial class AlterConfigsOptions
#region Instance methods
///
- ///
+ ///
///
///
public bool ShouldValidateOnly()
@@ -99,7 +99,7 @@ public bool ShouldValidateOnly()
return IExecuteWithSignature("shouldValidateOnly", "()Z");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsResult.cs
index e96db3179..d9025415e 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConfigsResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterConfigsResult declaration
///
- ///
+ ///
///
public partial class AlterConfigsResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -91,7 +91,7 @@ public partial class AlterConfigsResult
#region Instance methods
///
- ///
+ ///
///
///
public Java.Util.Map> Values()
@@ -99,7 +99,7 @@ public partial class AlterConfigsResult
return IExecuteWithSignature>>("values", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsOptions.cs
index 121d214c8..0dc23bd6b 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterConsumerGroupOffsetsOptions declaration
///
- ///
+ ///
///
public partial class AlterConsumerGroupOffsetsOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsResult.cs
index a5241b015..0f2bcbdb0 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterConsumerGroupOffsetsResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterConsumerGroupOffsetsResult declaration
///
- ///
+ ///
///
public partial class AlterConsumerGroupOffsetsResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -91,7 +91,7 @@ public partial class AlterConsumerGroupOffsetsResult
#region Instance methods
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
@@ -99,7 +99,7 @@ public partial class AlterConsumerGroupOffsetsResult
return IExecuteWithSignature>("all", "()Lorg/apache/kafka/common/KafkaFuture;");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsOptions.cs
index 0b47ce2ef..4d4897a6f 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterPartitionReassignmentsOptions declaration
///
- ///
+ ///
///
public partial class AlterPartitionReassignmentsOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsResult.cs
index cee2c7497..910394017 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterPartitionReassignmentsResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterPartitionReassignmentsResult declaration
///
- ///
+ ///
///
public partial class AlterPartitionReassignmentsResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -91,7 +91,7 @@ public partial class AlterPartitionReassignmentsResult
#region Instance methods
///
- ///
+ ///
///
///
public Java.Util.Map> Values()
@@ -99,7 +99,7 @@ public partial class AlterPartitionReassignmentsResult
return IExecuteWithSignature>>("values", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsOptions.cs
index e2d04cd1a..fafe96d90 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterReplicaLogDirsOptions declaration
///
- ///
+ ///
///
public partial class AlterReplicaLogDirsOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsResult.cs
index a389813e8..0d763eb7c 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterReplicaLogDirsResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterReplicaLogDirsResult declaration
///
- ///
+ ///
///
public partial class AlterReplicaLogDirsResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -91,7 +91,7 @@ public partial class AlterReplicaLogDirsResult
#region Instance methods
///
- ///
+ ///
///
///
public Java.Util.Map> Values()
@@ -99,7 +99,7 @@ public partial class AlterReplicaLogDirsResult
return IExecuteWithSignature>>("values", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsOptions.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsOptions.cs
index 564581bf5..cc7068d22 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsOptions.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsOptions.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterUserScramCredentialsOptions declaration
///
- ///
+ ///
///
public partial class AlterUserScramCredentialsOptions : Org.Apache.Kafka.Clients.Admin.AbstractOptions
{
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsResult.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsResult.cs
index b297d7bac..f73e4d88f 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsResult.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/AlterUserScramCredentialsResult.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region AlterUserScramCredentialsResult declaration
///
- ///
+ ///
///
public partial class AlterUserScramCredentialsResult : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -75,7 +75,7 @@ public partial class AlterUserScramCredentialsResult
{
#region Constructors
///
- ///
+ ///
///
///
public AlterUserScramCredentialsResult(Java.Util.Map> arg0)
@@ -99,7 +99,7 @@ public AlterUserScramCredentialsResult(Java.Util.Map
- ///
+ ///
///
///
public Java.Util.Map> Values()
@@ -107,7 +107,7 @@ public AlterUserScramCredentialsResult(Java.Util.Map>>("values", "()Ljava/util/Map;");
}
///
- ///
+ ///
///
///
public Org.Apache.Kafka.Common.KafkaFuture All()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ClientMetricsResourceListing.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ClientMetricsResourceListing.cs
index b665c9a2d..19d54533d 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ClientMetricsResourceListing.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ClientMetricsResourceListing.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region ClientMetricsResourceListing declaration
///
- ///
+ ///
///
public partial class ClientMetricsResourceListing : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -75,7 +75,7 @@ public partial class ClientMetricsResourceListing
{
#region Constructors
///
- ///
+ ///
///
///
public ClientMetricsResourceListing(Java.Lang.String arg0)
@@ -99,7 +99,7 @@ public ClientMetricsResourceListing(Java.Lang.String arg0)
#region Instance methods
///
- ///
+ ///
///
///
public Java.Lang.String Name()
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Config.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Config.cs
index 295aa2bd6..92821327d 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Config.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/Config.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region Config declaration
///
- ///
+ ///
///
public partial class Config : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -75,7 +75,7 @@ public partial class Config
{
#region Constructors
///
- ///
+ ///
///
///
public Config(Java.Util.Collection arg0)
@@ -99,7 +99,7 @@ public Config(Java.Util.Collection a
#region Instance methods
///
- ///
+ ///
///
///
public Java.Util.Collection Entries()
@@ -107,7 +107,7 @@ public Config(Java.Util.Collection a
return IExecuteWithSignature>("entries", "()Ljava/util/Collection;");
}
///
- ///
+ ///
///
///
///
diff --git a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ConfigEntry.cs b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ConfigEntry.cs
index 71520551b..6f1674599 100644
--- a/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ConfigEntry.cs
+++ b/src/net/KNet/Generated/Org/Apache/Kafka/Clients/Admin/ConfigEntry.cs
@@ -17,8 +17,8 @@
*/
/*
-* This file is generated by MASES.JNetReflector (ver. 2.5.9.0)
-* using kafka-clients-3.8.0.jar as reference
+* This file is generated by MASES.JNetReflector (ver. 2.5.10.0)
+* using kafka-clients-3.8.1.jar as reference
*/
using MASES.JCOBridge.C2JBridge;
@@ -27,7 +27,7 @@ namespace Org.Apache.Kafka.Clients.Admin
{
#region ConfigEntry declaration
///
- ///
+ ///
///
public partial class ConfigEntry : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -68,7 +68,7 @@ public ConfigEntry(params object[] args) : base(args) { }
// TODO: complete the class
#region ConfigSource declaration
///
- ///
+ ///
///
public partial class ConfigSource : Java.Lang.Enum
{
@@ -113,7 +113,7 @@ public ConfigSource(params object[] args) : base(args) { }
#region ConfigSynonym declaration
///
- ///
+ ///
///
public partial class ConfigSynonym : MASES.JCOBridge.C2JBridge.JVMBridgeBase
{
@@ -158,7 +158,7 @@ public ConfigSynonym(params object[] args) : base(args) { }
#region ConfigType declaration
///
- ///
+ ///
///
public partial class ConfigType : Java.Lang.Enum
{
@@ -210,7 +210,7 @@ public partial class ConfigEntry
{
#region Constructors
///
- ///
+ ///
///
///
///
@@ -225,7 +225,7 @@ public ConfigEntry(Java.Lang.String arg0, Java.Lang.String arg1, Org.Apache.Kafk
{
}
///
- ///
+ ///
///
///
///
@@ -250,7 +250,7 @@ public ConfigEntry(Java.Lang.String arg0, Java.Lang.String arg1)
#region Instance methods
///
- ///
+ ///
///
///
public bool IsDefault()
@@ -258,7 +258,7 @@ public bool IsDefault()
return IExecuteWithSignature("isDefault", "()Z");
}
///
- ///
+ ///
///
///
public bool IsReadOnly()
@@ -266,7 +266,7 @@ public bool IsReadOnly()
return IExecuteWithSignature("isReadOnly", "()Z");
}
///
- ///