Skip to content

Commit 2e6db45

Browse files
bugfix for getting original configs that comes as strings
1 parent efce84f commit 2e6db45

File tree

5 files changed

+6
-6
lines changed

5 files changed

+6
-6
lines changed

.idea/runConfigurations/debug_kafka_clients_example.xml

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

superstream-clients/dependency-reduced-pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
<groupId>ai.superstream</groupId>
55
<artifactId>superstream-clients</artifactId>
66
<name>Superstream Kafka Client Optimizer</name>
7-
<version>1.0.4</version>
7+
<version>1.0.5</version>
88
<description>A Java library that dynamically optimizes Kafka client configuration based on recommendations</description>
99
<url>https://github.com/superstreamlabs/superstream-clients-java</url>
1010
<developers>

superstream-clients/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>ai.superstream</groupId>
88
<artifactId>superstream-clients</artifactId>
9-
<version>1.0.4</version>
9+
<version>1.0.5</version>
1010
<packaging>jar</packaging>
1111

1212
<name>Superstream Kafka Client Optimizer</name>

superstream-clients/src/main/java/ai/superstream/core/ClientReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public boolean reportClient(String bootstrapServers, Properties originalClientPr
5757

5858
properties.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "zstd");
5959
properties.put(ProducerConfig.BATCH_SIZE_CONFIG, 16384); // 16KB batch size
60-
properties.put(ProducerConfig.LINGER_MS_CONFIG, 1000); // 500ms linger
60+
properties.put(ProducerConfig.LINGER_MS_CONFIG, 1000);
6161

6262
try (Producer<String, String> producer = new KafkaProducer<>(properties)) {
6363
// Create the client message

superstream-clients/src/main/java/ai/superstream/core/SuperstreamManager.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,8 @@ public static SuperstreamManager getInstance() {
7474

7575
public static Map<String, Object> convertPropertiesToMap(Properties properties) {
7676
Map<String, Object> map = new HashMap<>();
77-
for (String name : properties.stringPropertyNames()) {
78-
map.put(name, properties.getProperty(name));
77+
for (Map.Entry<Object, Object> entry : properties.entrySet()) {
78+
map.put(String.valueOf(entry.getKey()), entry.getValue());
7979
}
8080
return map;
8181
}

0 commit comments

Comments
 (0)