Skip to content

Commit 8c6f7a1

Browse files
committed
MINOR: Simplify DynamicLogConfig log override merge
1 parent 74c5749 commit 8c6f7a1

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

server/src/main/java/org/apache/kafka/server/config/DynamicLogConfig.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -147,9 +147,11 @@ private void updateLogsConfig(Map<String, Object> newBrokerDefaults) {
147147
logManager.brokerConfigUpdated();
148148
for (UnifiedLog unifiedLog : logManager.allLogs()) {
149149
Map<String, Object> props = new HashMap<>(newBrokerDefaults);
150-
unifiedLog.config().originals().entrySet().stream()
151-
.filter(entry -> unifiedLog.config().overriddenConfigs.contains(entry.getKey()))
152-
.forEach(entry -> props.put(entry.getKey(), entry.getValue()));
150+
unifiedLog.config().originals().forEach((key, value) -> {
151+
if (unifiedLog.config().overriddenConfigs.contains(key)) {
152+
props.put(key, value);
153+
}
154+
});
153155
unifiedLog.updateConfig(new LogConfig(props, unifiedLog.config().overriddenConfigs));
154156
}
155157
}

0 commit comments

Comments
 (0)