Add share group support, update to Java 25, Kafka client 4.2.0

.github/workflows/build.yml

@@ -16,7 +16,7 @@ jobs:
       - name: Setup JDK
         uses: actions/setup-java@v5
         with:
-          java-version: '21'
+          java-version: '25'
           distribution: 'temurin'
           cache: maven
 

.github/workflows/release.yml

@@ -30,7 +30,7 @@ jobs:
       - name: Setup JDK
         uses: actions/setup-java@v5
         with:
-          java-version: '21'
+          java-version: '25'
           distribution: 'temurin'
 
       - name: Build and Push API Image

pom.xml

@@ -6,12 +6,13 @@
   <version>0.5.1-SNAPSHOT</version>
   <properties>
     <compiler-plugin.version>3.15.0</compiler-plugin.version>
-    <maven.compiler.release>21</maven.compiler.release>
+    <maven.compiler.release>25</maven.compiler.release>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
     <quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
     <quarkus.platform.version>3.31.4</quarkus.platform.version>
+    <kafka-clients.version>4.2.0</kafka-clients.version>
     <strimzi-oauth.version>0.17.1</strimzi-oauth.version>
     <skipITs>true</skipITs>
     <surefire-plugin.version>3.5.5</surefire-plugin.version>
@@ -23,6 +24,11 @@
   </scm>
   <dependencyManagement>
     <dependencies>
+      <dependency>
+        <groupId>org.apache.kafka</groupId>
+        <artifactId>kafka-clients</artifactId>
+        <version>${kafka-clients.version}</version>
+      </dependency>
       <dependency>
         <groupId>${quarkus.platform.group-id}</groupId>
         <artifactId>${quarkus.platform.artifact-id}</artifactId>

src/main/docker/Dockerfile.jvm

@@ -77,7 +77,7 @@
 #   accessed directly. (example: "foo.example.com,bar.example.com")
 #
 ###
-FROM registry.access.redhat.com/ubi9/openjdk-21:1.24-2.1771324989
+FROM registry.access.redhat.com/ubi9/openjdk-25:1.24-2.1772091451
 
 ENV LANGUAGE='en_US:en'
 

src/main/java/com/github/streamshub/DataGenConfig.java

@@ -1,6 +1,7 @@
 package com.github.streamshub;
 
 import java.util.Map;
+import java.util.Optional;
 
 import io.smallrye.config.ConfigMapping;
 
@@ -9,8 +10,20 @@ public interface DataGenConfig {
 
     boolean enabled();
 
+    int consumerGroupCount();
+
+    int shareGroupCount();
+
+    int topicsPerMember();
+
+    int partitionsPerTopic();
+
+    Optional<Short> topicReplicationFactor();
+
     String topicPattern();
 
+    int maxTopicDepth();
+
     DataGenConfig.Security security();
 
     Map<String, DataGenConfig.KafkaConfig> kafka();