fix

kiegroup · Mar 22, 2021 · 87bc8f9 · 87bc8f9
1 parent 833992c
commit 87bc8f9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/controller/kieapp/defaults/defaults.go b/pkg/controller/kieapp/defaults/defaults.go
@@ -1019,7 +1019,7 @@ func getJmsConfig(environment api.EnvironmentType, jms *api.KieAppJmsObject) (*a
 }
 
 func getKafkaConfig(kafka *api.KafkaExtObject) (*api.KafkaExtObject, error) {
-	if kafka == nil || kafka.ExtEnabled {
+	if kafka == nil || !kafka.ExtEnabled {
 		return nil, nil
 	}