From acb801aaa06ce171e143dabdacc5ca2535a1cd08 Mon Sep 17 00:00:00 2001 From: Sergii Koshel Date: Mon, 1 Nov 2021 12:56:34 +0200 Subject: [PATCH] Add missing ExternalTrafficPolicy in MeshGateway --- pkg/resources/istioingress/meshgateway.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/resources/istioingress/meshgateway.go b/pkg/resources/istioingress/meshgateway.go index 999472ee8..c13151864 100644 --- a/pkg/resources/istioingress/meshgateway.go +++ b/pkg/resources/istioingress/meshgateway.go @@ -62,7 +62,8 @@ func (r *Reconciler) meshgateway(log logr.Logger, externalListenerConfig v1beta1 PodAnnotations: ingressConfig.IstioIngressConfig.GetAnnotations(), }, }, - ServiceType: ingressConfig.GetServiceType(), + ServiceType: ingressConfig.GetServiceType(), + ServiceExternalTrafficPolicy: ingressConfig.ExternalTrafficPolicy, }, Ports: generateExternalPorts(r.KafkaCluster, util.GetBrokerIdsFromStatusAndSpec(r.KafkaCluster.Status.BrokersState, r.KafkaCluster.Spec.Brokers, log),