Skip to content

Commit

Permalink
Upgrade to JNet 2.0.2 (#267)
Browse files Browse the repository at this point in the history 
* Update generated code with latest JNetReflector version

* Configuration and code alignment

* Upgrade to JNet 2.0.2
  • Loading branch information
@masesdevelopers
masesdevelopers authored Oct 18, 2023
1 parent 4d82682 commit ffb7c7a
Show file tree
Hide file tree
Showing 1,006 changed files with 3,188 additions and 1,815 deletions.
2 changes: 2 additions & 0 deletions src/configuration.json
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,6 @@
{
"RelativeDestinationCSharpClassPath": "net\\KNet\\Generated",
"RelativeDestinationJavaListenerPath": "java\\knet\\src\\main\\java",
"JavaListenerBasePackage": "org.mases.knet.generated",
"OnlyPropertiesForGetterSetter": true,
"DisableInterfaceMethodGeneration": true,
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerInterceptor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.consumer;
Expand Down
2 changes: 1 addition & 1 deletion ...org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.consumer;
Expand Down
2 changes: 1 addition & 1 deletion ...org/mases/knet/generated/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.consumer;
Expand Down
2 changes: 1 addition & 1 deletion ...java/org/mases/knet/generated/org/apache/kafka/clients/consumer/OffsetCommitCallback.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.consumer;
Expand Down
2 changes: 1 addition & 1 deletion ...et/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Callback.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.producer;
Expand Down
2 changes: 1 addition & 1 deletion ...src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.producer;
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/mases/knet/generated/org/apache/kafka/clients/producer/ProducerInterceptor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.clients.producer;
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/org/mases/knet/generated/org/apache/kafka/common/ClusterResourceListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.common;
Expand Down
2 changes: 1 addition & 1 deletion ...in/java/org/mases/knet/generated/org/apache/kafka/common/config/ConfigChangeCallback.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.common.config;
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/org/mases/knet/generated/org/apache/kafka/common/metrics/MetricsReporter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.common.metrics;
Expand Down
6 changes: 5 additions & 1 deletion ...ain/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Deserializer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.common.serialization;
Expand All @@ -36,6 +36,10 @@ public java.lang.Object deserialize(java.lang.String arg0, org.apache.kafka.comm
raiseEvent("deserialize3", arg0, arg1, arg2); Object retVal = getReturnData(); return (java.lang.Object)retVal;
}
//@Override
public java.lang.Object deserialize(java.lang.String arg0, org.apache.kafka.common.header.Headers arg1, java.nio.ByteBuffer arg2) {
raiseEvent("deserialize3_2", arg0, arg1, arg2); Object retVal = getReturnData(); return (java.lang.Object)retVal;
}
//@Override
public void close() {
raiseEvent("close");
}
Expand Down
2 changes: 1 addition & 1 deletion .../main/java/org/mases/knet/generated/org/apache/kafka/common/serialization/Serializer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.common.serialization;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/mases/knet/generated/org/apache/kafka/streams/KafkaClientSupplier.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams;
Expand Down
2 changes: 1 addition & 1 deletion ...a/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/StateListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams;
Expand Down
2 changes: 1 addition & 1 deletion ...mases/knet/generated/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.errors;
Expand Down
2 changes: 1 addition & 1 deletion ...t/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Aggregator.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...rc/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ForeachAction.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Initializer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/KeyValueMapper.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion .../knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Merger.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...et/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Predicate.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Reducer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoiner.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...in/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapper.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...in/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueMapperWithKey.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...va/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.kstream;
Expand Down
2 changes: 1 addition & 1 deletion ...mases/knet/generated/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion ...ava/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreCallback.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion ...ava/org/mases/knet/generated/org/apache/kafka/streams/processor/StateRestoreListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion ...n/java/org/mases/knet/generated/org/apache/kafka/streams/processor/StreamPartitioner.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/mases/knet/generated/org/apache/kafka/streams/processor/TimestampExtractor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion .../java/org/mases/knet/generated/org/apache/kafka/streams/processor/TopicNameExtractor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor;
Expand Down
2 changes: 1 addition & 1 deletion ...va/org/mases/knet/generated/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
Expand Down
2 changes: 1 addition & 1 deletion .../main/java/org/mases/knet/generated/org/apache/kafka/streams/processor/api/Processor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
*/

package org.mases.knet.generated.org.apache.kafka.streams.processor.api;
Expand Down
2 changes: 1 addition & 1 deletion src/net/KNet/Developed/Org/Apache/Kafka/Tools/StreamsResetter.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ static bool ResetApplication(bool force, string bootstrapserver, string applicat
}
if (force) strings.Add("--force");

return new StreamsResetter().Run(strings.ToArray()) == 0;
return new StreamsResetter().Execute(strings.ToArray()) == 0;
}
}
#endregion
Expand Down
2 changes: 1 addition & 1 deletion src/net/KNet/Generated/Kafka/Admin/AclCommand.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
* using kafka_2.13-3.6.0.jar as reference
*/

Expand Down
2 changes: 1 addition & 1 deletion src/net/KNet/Generated/Kafka/Admin/AllPackageClasses.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
* using kafka_2.13-3.6.0.jar as reference
*/

Expand Down
2 changes: 1 addition & 1 deletion src/net/KNet/Generated/Kafka/Admin/BrokerApiVersionsCommand.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
* using kafka_2.13-3.6.0.jar as reference
*/

Expand Down
2 changes: 1 addition & 1 deletion src/net/KNet/Generated/Kafka/Admin/ConfigCommand.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
*/

/*
* This file is generated by MASES.JNetReflector (ver. 2.0.1.0)
* This file is generated by MASES.JNetReflector (ver. 2.0.2.0)
* using kafka_2.13-3.6.0.jar as reference
*/

Expand Down
Loading

0 comments on commit ffb7c7a

Please sign in to comment.