Skip to content

Commit e7e1b0d

Browse files
committed
Add share group support, update to Java 25, Kafka client 4.2.0
Signed-off-by: Michael Edgar <medgar@redhat.com>
1 parent 9ee81fa commit e7e1b0d

7 files changed

Lines changed: 180 additions & 126 deletions

File tree

pom.xml

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
<version>0.5.1-SNAPSHOT</version>
77
<properties>
88
<compiler-plugin.version>3.15.0</compiler-plugin.version>
9-
<maven.compiler.release>21</maven.compiler.release>
9+
<maven.compiler.release>25</maven.compiler.release>
1010
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
1111
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
1212
<quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
@@ -23,6 +23,11 @@
2323
</scm>
2424
<dependencyManagement>
2525
<dependencies>
26+
<dependency>
27+
<groupId>org.apache.kafka</groupId>
28+
<artifactId>kafka-clients</artifactId>
29+
<version>4.2.0</version>
30+
</dependency>
2631
<dependency>
2732
<groupId>${quarkus.platform.group-id}</groupId>
2833
<artifactId>${quarkus.platform.artifact-id}</artifactId>

src/main/docker/Dockerfile.jvm

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@
7777
# accessed directly. (example: "foo.example.com,bar.example.com")
7878
#
7979
###
80-
FROM registry.access.redhat.com/ubi9/openjdk-21:1.24-2.1771324989
80+
FROM registry.access.redhat.com/ubi9/openjdk-25:1.24-2.1771324969
8181

8282
ENV LANGUAGE='en_US:en'
8383

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

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.github.streamshub;
22

33
import java.util.Map;
4+
import java.util.Optional;
45

56
import io.smallrye.config.ConfigMapping;
67

@@ -9,8 +10,20 @@ public interface DataGenConfig {
910

1011
boolean enabled();
1112

13+
int consumerGroupCount();
14+
15+
int shareGroupCount();
16+
17+
int topicsPerMember();
18+
19+
int partitionsPerTopic();
20+
21+
Optional<Short> topicReplicationFactor();
22+
1223
String topicPattern();
1324

25+
int maxTopicDepth();
26+
1427
DataGenConfig.Security security();
1528

1629
Map<String, DataGenConfig.KafkaConfig> kafka();

0 commit comments

Comments
 (0)