Add missing ExternalTrafficPolicy in MeshGateway

banzaicloud · Nov 3, 2021 · acb801a · acb801a
1 parent 5b8a0c0
commit acb801a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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),