Skip to content

Commit 60b6d6d

Browse files
Adjust log levels and update pom (#41)
* Change log level from DEBUG to INFO in ConfigurationOptimizer and SuperstreamManager Co-authored-by: idan <[email protected]> * Changes from background agent bc-15f8c2bf-ef92-4d5d-b3dc-64c2014f9e0e --------- Co-authored-by: Cursor Agent <[email protected]>
1 parent 1e08f48 commit 60b6d6d

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

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.207</version>
9+
<version>1.0.208</version>
1010
<packaging>jar</packaging>
1111

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

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ public Map<String, Object> getOptimalConfiguration(MetadataMessage metadataMessa
8181
// If latency sensitive, remove linger.ms setting
8282
if (isLatencySensitive && optimalConfiguration.containsKey("linger.ms")) {
8383
optimalConfiguration.remove("linger.ms");
84-
logger.debug("Ignore linger.ms from optimizations due to latency-sensitive configuration");
84+
logger.info("Ignore linger.ms from optimizations due to latency-sensitive configuration");
8585
}
8686

8787
return optimalConfiguration;
@@ -113,7 +113,7 @@ public List<String> applyOptimalConfiguration(Properties properties, Map<String,
113113

114114
// Skip linger.ms optimization if the application is latency-sensitive
115115
if ("linger.ms".equals(key) && isLatencySensitive) {
116-
logger.debug("Skipping linger.ms optimization due to latency-sensitive configuration");
116+
logger.info("Skipping linger.ms optimization due to latency-sensitive configuration");
117117
continue;
118118
}
119119

@@ -164,9 +164,9 @@ public List<String> applyOptimalConfiguration(Properties properties, Map<String,
164164
modifiedKeys.add(key);
165165

166166
if (originalValue == null) {
167-
logger.debug("Setting configuration: {}={} (was not previously set)", key, value);
167+
logger.info("Setting configuration: {}={} (was not previously set)", key, value);
168168
} else {
169-
logger.debug("Overriding configuration: {}={} (was: {})", key, value, originalValue);
169+
logger.info("Overriding configuration: {}={} (was: {})", key, value, originalValue);
170170
}
171171
}
172172

0 commit comments

Comments
 (0)