Skip to content

Commit 04a5661

Browse files
committed
Remove logging
1 parent 600dc73 commit 04a5661

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

pkg/resources/kafka/configmap.go

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -437,12 +437,7 @@ func generateListenerSpecificConfig(kcs *v1beta1.KafkaClusterSpec, serverPasses
437437
b := broker.ReadOnlyConfig
438438
trimmedConfig := strings.TrimSpace(b)
439439

440-
if strings.Contains(trimmedConfig, kafkautils.KafkaConfigSecurityInterBrokerProtocol+"=") {
441-
log.Info("Security InterBrokerProtocol is set for this broker, skipping config update", "broker", broker)
442-
} else {
443-
log.Info("Security InterBrokerProtocol NOT found for broker, setting inter.broker.listener.name",
444-
"interBrokerListenerName", interBrokerListenerName, "broker", broker)
445-
440+
if !strings.Contains(trimmedConfig, kafkautils.KafkaConfigSecurityInterBrokerProtocol+"=") {
446441
if err := brokerConfig.Set(kafkautils.KafkaConfigInterBrokerListenerName, interBrokerListenerName); err != nil {
447442
log.Error(err, fmt.Sprintf("setting '%s' parameter in broker configuration resulted in an error",
448443
kafkautils.KafkaConfigInterBrokerListenerName))

0 commit comments

Comments
 (0)