External Port only if config enables it

RedHatInsights · Jun 16, 2022 · 4a583a4 · 4a583a4
1 parent 0efd345
commit 4a583a4
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/clowder-config.yaml b/clowder-config.yaml
@@ -6,7 +6,8 @@ data:
             "createServiceMonitor": true,
             "watchStrimziResources": true,
             "enableKedaResources": true,
-            "reconciliationMetrics": true
+            "reconciliationMetrics": true,
+            "enableExternalStrimzi": true
         }
     }
 kind: ConfigMap

diff --git a/controllers/cloud.redhat.com/clowderconfig/config.go b/controllers/cloud.redhat.com/clowderconfig/config.go
@@ -46,6 +46,7 @@ type ClowderConfig struct {
 		PerProviderMetrics          bool `json:"perProviderMetrics"`
 		ReconciliationMetrics       bool `json:"reconciliationMetrics"`
 		DisableCloudWatchLogging    bool `json:"disableCloudWatchLogging"`
+		EnableExternalStrimzi       bool `json:"enableExternalStrimzi"`
 	} `json:"features"`
 }
 

diff --git a/controllers/cloud.redhat.com/providers/kafka/strimzi.go b/controllers/cloud.redhat.com/providers/kafka/strimzi.go
@@ -255,7 +255,7 @@ func (s *strimziProvider) configureKafkaCluster() error {
 
 	k.Spec.Kafka.Listeners = []strimzi.KafkaSpecKafkaListenersElem{listener}
 
-	if s.Env.Spec.Providers.Kafka.EnableLegacyStrimzi {
+	if clowderconfig.LoadedConfig.Features.EnableExternalStrimzi {
 		externalHost := "localhost"
 		externalPort := int32(9094)
 		externalListener := strimzi.KafkaSpecKafkaListenersElem{