diff --git a/topic-operator/src/main/java/io/strimzi/operator/topic/BatchingTopicController.java b/topic-operator/src/main/java/io/strimzi/operator/topic/BatchingTopicController.java index f5856a0a3d..bb7775c7c5 100644 --- a/topic-operator/src/main/java/io/strimzi/operator/topic/BatchingTopicController.java +++ b/topic-operator/src/main/java/io/strimzi/operator/topic/BatchingTopicController.java @@ -535,8 +535,8 @@ private Results filterOutNonAlterableConfigChanges( reconcilableTopics.forEach(reconcilableTopic -> { var configChanges = results.getConfigChanges().stream() .filter(pair -> pair.getKey().equals(reconcilableTopic)).findFirst(); - if (configChanges != null && configChanges.isEmpty()) { - LOGGER.debugCr(reconcilableTopic.reconciliation(), "Config changes {}", configChanges); + if (configChanges.isPresent()) { + LOGGER.debugCr(reconcilableTopic.reconciliation(), "Config changes: {}", configChanges.get()); } else { LOGGER.debugCr(reconcilableTopic.reconciliation(), "No config change"); }