Skip to content

Commit

Permalink
No LB on envoy
Browse files Browse the repository at this point in the history
  • Loading branch information
amuraru committed Jun 1, 2020
1 parent d1e396a commit bb5b586
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion pkg/resources/envoy/envoy.go
Original file line number Diff line number Diff line change
Expand Up @@ -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,
} {
Expand Down
10 changes: 5 additions & 5 deletions pkg/resources/kafka/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down

0 comments on commit bb5b586

Please sign in to comment.