Skip to content

Commit 0b3c91a

Browse files
Update generated classes using last public version of JNetReflector after commit 66325c6 (#915)
* Changes by GitHub action * Fix incompatible type * Update wrong namespace * Removed unmanaged class * Added new packages * Removed deprecated classes * Update generated classes using last public version of JNetReflector after commit 6a4d33f (#916) * Changes by GitHub action * Alignment of developed code * Manual fix of generated code * Upgrade workflows to Java 17 --------- Co-authored-by: masesdevelopers <[email protected]> --------- Co-authored-by: masesdevelopers <[email protected]> Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
1 parent 66325c6 commit 0b3c91a

File tree

1,124 files changed

+15655
-5333
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

1,124 files changed

+15655
-5333
lines changed

.github/workflows/build.yaml

+2-2
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ jobs:
126126
uses: actions/setup-java@v4
127127
with: # running setup-java again overwrites the settings.xml
128128
distribution: temurin
129-
java-version: 11
129+
java-version: 17
130130
cache: 'maven'
131131
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
132132
server-username: MAVEN_USERNAME # env variable for username in deploy
@@ -274,7 +274,7 @@ jobs:
274274
uses: actions/setup-java@v4
275275
with: # running setup-java again overwrites the settings.xml
276276
distribution: temurin
277-
java-version: 11
277+
java-version: 17
278278
cache: 'maven'
279279
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
280280
server-username: MAVEN_USERNAME # env variable for username in deploy

.github/workflows/codeql-analysis.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ jobs:
121121
uses: actions/setup-java@v4
122122
with: # running setup-java again overwrites the settings.xml
123123
distribution: temurin
124-
java-version: 11
124+
java-version: 17
125125
cache: 'maven'
126126

127127
- name: Maven preparation (step 1)

.github/workflows/docker.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ jobs:
4141
uses: actions/setup-java@v4
4242
with: # running setup-java again overwrites the settings.xml
4343
distribution: temurin
44-
java-version: 11
44+
java-version: 17
4545
cache: 'maven'
4646
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
4747
server-username: MAVEN_USERNAME # env variable for username in deploy

.github/workflows/pullrequest.yaml

+2-2
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ jobs:
8787
uses: actions/setup-java@v4
8888
with: # running setup-java again overwrites the settings.xml
8989
distribution: temurin
90-
java-version: 11
90+
java-version: 17
9191
cache: 'maven'
9292
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
9393
server-username: MAVEN_USERNAME # env variable for username in deploy
@@ -136,7 +136,7 @@ jobs:
136136
uses: actions/setup-java@v4
137137
with: # running setup-java again overwrites the settings.xml
138138
distribution: temurin
139-
java-version: 11
139+
java-version: 17
140140
cache: 'maven'
141141
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
142142
server-username: MAVEN_USERNAME # env variable for username in deploy

.github/workflows/release.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ jobs:
3838
uses: actions/setup-java@v4
3939
with: # running setup-java again overwrites the settings.xml
4040
distribution: temurin
41-
java-version: 11
41+
java-version: 17
4242
cache: 'maven'
4343
server-id: ossrh # Value of the distributionManagement/repository/id field of the pom.xml
4444
server-username: MAVEN_USERNAME # env variable for username in deploy

src/configuration.json

+12-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,9 @@
1010
"kafka_2.13-4.0.0.jar",
1111
"kafka-clients-4.0.0.jar",
1212
"kafka-streams-4.0.0.jar",
13+
"kafka-streams-scala_2.13-4.0.0.jar",
1314
"kafka-tools-4.0.0.jar",
15+
"kafka-tools-api-4.0.0.jar",
1416
"kafka-raft-4.0.0.jar",
1517
"kafka-shell-4.0.0.jar",
1618
"connect-api-4.0.0.jar",
@@ -20,7 +22,7 @@
2022
"connect-mirror-client-4.0.0.jar",
2123
"connect-runtime-4.0.0.jar",
2224
"connect-transforms-4.0.0.jar",
23-
"kafka-server-common-4.0.0.jar"
25+
"kafka-server-common-4.0.0.jar"
2426
],
2527
"OriginJavadocJARVersionAndUrls": [
2628
{
@@ -35,10 +37,18 @@
3537
"Version": 8,
3638
"Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/"
3739
},
40+
{
41+
"Version": 8,
42+
"Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-streams-scala_2.13/3.9.0/"
43+
},
3844
{
3945
"Version": 8,
4046
"Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/3.9.0/"
4147
},
48+
{
49+
"Version": 8,
50+
"Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-tools-api/3.9.0/"
51+
},
4252
{
4353
"Version": 8,
4454
"Url": "https://www.javadoc.io/doc/org.apache.kafka/kafka-raft/3.9.0/"
@@ -219,6 +229,7 @@
219229
"org.apache.kafka.connect.cli.AbstractConnectCli",
220230
"org.apache.kafka.connect.rest.ConnectRestExtensionContext",
221231
"org.apache.kafka.connect.rest.ConnectRestExtension",
232+
"org.apache.kafka.connect.rest.basic.auth.extension.JaasBasicAuthFilter",
222233
"org.apache.kafka.connect.storage.HeaderConverter",
223234
"org.apache.kafka.connect.storage.SimpleHeaderConverter",
224235
"org.apache.kafka.connect.util.SharedTopicAdmin",

src/jvm/knet/src/main/java/org/mases/knet/developed/clients/consumer/KNetConsumer.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public KNetConsumer(Map<String, Object> configs, Deserializer<byte[]> keyDeseria
4949
}
5050

5151
public void consume(long timeoutMs) {
52-
ConsumerRecords<byte[], byte[]> records = super.poll(timeoutMs);
52+
ConsumerRecords<byte[], byte[]> records = super.poll(Duration.ofMillis(timeoutMs));
5353
for (ConsumerRecord<byte[], byte[]> record : records) {
5454
if (_callback != null) _callback.recordReady(record);
5555
}

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/clients/producer/Partitioner.java

-9
Original file line numberDiff line numberDiff line change
@@ -85,14 +85,5 @@ public void configure(java.util.Map arg0) {
8585
org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
8686
raiseEvent("configure", eventDataExchange, arg0); if (!eventDataExchange.getHasOverride()) throw new UnsupportedOperationException("The method shall be implemented in .NET side since does not have a default implementation within the JVM");
8787
}
88-
//@Override
89-
public void onNewBatch(java.lang.String arg0, org.apache.kafka.common.Cluster arg1, int arg2) {
90-
org.mases.jnet.developed.JNetEventResult eventDataExchange = new org.mases.jnet.developed.JNetEventResult();
91-
raiseEvent("onNewBatch", eventDataExchange, arg0, arg1, arg2); if (!eventDataExchange.getHasOverride()) org.apache.kafka.clients.producer.Partitioner.super.onNewBatch(arg0, arg1, arg2);
92-
}
93-
//@Override
94-
public void onNewBatchDefault(java.lang.String arg0, org.apache.kafka.common.Cluster arg1, int arg2) {
95-
org.apache.kafka.clients.producer.Partitioner.super.onNewBatch(arg0, arg1, arg2);
96-
}
9788

9889
}

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/metadata/FeatureLevelListener.java

-79
This file was deleted.

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/Transformer.java

-89
This file was deleted.

src/jvm/knet/src/main/java/org/mases/knet/generated/org/apache/kafka/streams/kstream/ValueTransformer.java

-89
This file was deleted.

0 commit comments

Comments
 (0)