From bb5b58694c76258667227769efd545e4b8a6caee Mon Sep 17 00:00:00 2001 From: Adi Muraru Date: Thu, 5 Mar 2020 15:05:31 +0200 Subject: [PATCH] No LB on envoy --- pkg/resources/envoy/envoy.go | 2 +- pkg/resources/kafka/kafka.go | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/pkg/resources/envoy/envoy.go b/pkg/resources/envoy/envoy.go index fb24b4f9f..6a27c721e 100644 --- a/pkg/resources/envoy/envoy.go +++ b/pkg/resources/envoy/envoy.go @@ -57,7 +57,7 @@ func (r *Reconciler) Reconcile(log logr.Logger) error { if r.KafkaCluster.Spec.ListenersConfig.ExternalListeners != nil && r.KafkaCluster.Spec.GetIngressController() == envoyutils.IngressControllerName { for _, res := range []resources.ResourceWithLogs{ - r.loadBalancer, + //r.loadBalancer, r.configMap, r.deployment, } { diff --git a/pkg/resources/kafka/kafka.go b/pkg/resources/kafka/kafka.go index bb38be3a1..0144c001c 100644 --- a/pkg/resources/kafka/kafka.go +++ b/pkg/resources/kafka/kafka.go @@ -198,11 +198,11 @@ func (r *Reconciler) Reconcile(log logr.Logger) error { // first element of slice will be used for external advertised listener lbIPs = append(lbIPs, r.KafkaCluster.Spec.ListenersConfig.ExternalListeners[0].HostnameOverride) } - lbIP, err := getLoadBalancerIP(r.Client, r.KafkaCluster.Namespace, r.KafkaCluster.Spec.GetIngressController(), r.KafkaCluster.Name, log) - if err != nil { - return err - } - lbIPs = append(lbIPs, lbIP) + //lbIP, err := getLoadBalancerIP(r.Client, r.KafkaCluster.Namespace, r.KafkaCluster.Spec.GetIngressController(), r.KafkaCluster.Name, log) + //if err != nil { + // return err + //} + //lbIPs = append(lbIPs, lbIP) } //TODO remove after testing //lBIp := "192.168.0.1"