Skip to content

Commit dd341be

Browse files
committed
No LB on envoy
1 parent 164fa66 commit dd341be

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

pkg/resources/envoy/envoy.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ func (r *Reconciler) Reconcile(log logr.Logger) error {
5757
if r.KafkaCluster.Spec.ListenersConfig.ExternalListeners != nil && r.KafkaCluster.Spec.GetIngressController() == envoyutils.IngressControllerName {
5858

5959
for _, res := range []resources.ResourceWithLogs{
60-
r.loadBalancer,
60+
//r.loadBalancer,
6161
r.configMap,
6262
r.deployment,
6363
} {

pkg/resources/kafka/kafka.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -198,11 +198,11 @@ func (r *Reconciler) Reconcile(log logr.Logger) error {
198198
// first element of slice will be used for external advertised listener
199199
lbIPs = append(lbIPs, r.KafkaCluster.Spec.ListenersConfig.ExternalListeners[0].HostnameOverride)
200200
}
201-
lbIP, err := getLoadBalancerIP(r.Client, r.KafkaCluster.Namespace, r.KafkaCluster.Spec.GetIngressController(), r.KafkaCluster.Name, log)
202-
if err != nil {
203-
return err
204-
}
205-
lbIPs = append(lbIPs, lbIP)
201+
//lbIP, err := getLoadBalancerIP(r.Client, r.KafkaCluster.Namespace, r.KafkaCluster.Spec.GetIngressController(), r.KafkaCluster.Name, log)
202+
//if err != nil {
203+
// return err
204+
//}
205+
//lbIPs = append(lbIPs, lbIP)
206206
}
207207
//TODO remove after testing
208208
//lBIp := "192.168.0.1"

0 commit comments

Comments
 (0)