Add Envoy support for HTTP/1.0 health-check requests

api/v1beta1/kafkacluster_types.go

@@ -321,6 +321,8 @@ type EnvoyConfig struct {
 	// If not specified, the Envoy pods' priority is default to zero
 	// +optional
 	PriorityClassName string `json:"priorityClassName,omitempty"`
+	// EnableHealthCheckHttp10 is a toggle for adding HTTP1.0 support to Envoy health-check
+	EnableHealthCheckHttp10 bool `json:"enableHealthCheckHttp10,omitempty"`
 }
 
 // EnvoyCommandLineArgs defines envoy command line arguments

charts/kafka-operator/templates/crds.yaml

@@ -16549,6 +16549,10 @@ spec:
                         - maxUnavailable
                         type: string
                     type: object
+                  enableHealthCheckHttp10:
+                    description: EnableHealthCheckHttp10 is a toggle for adding HTTP1.0
+                      support to Envoy health-check
+                    type: boolean
                   envoyCommandLineArgs:
                     description: Envoy command line arguments
                     properties:
@@ -18555,6 +18559,11 @@ spec:
                                             - maxUnavailable
                                             type: string
                                         type: object
+                                      enableHealthCheckHttp10:
+                                        description: EnableHealthCheckHttp10 is a
+                                          toggle for adding HTTP1.0 support to Envoy
+                                          health-check
+                                        type: boolean
                                       envoyCommandLineArgs:
                                         description: Envoy command line arguments
                                         properties:

config/base/crds/kafka.banzaicloud.io_kafkaclusters.yaml

@@ -16548,6 +16548,10 @@ spec:
                         - maxUnavailable
                         type: string
                     type: object
+                  enableHealthCheckHttp10:
+                    description: EnableHealthCheckHttp10 is a toggle for adding HTTP1.0
+                      support to Envoy health-check
+                    type: boolean
                   envoyCommandLineArgs:
                     description: Envoy command line arguments
                     properties:
@@ -18554,6 +18558,11 @@ spec:
                                             - maxUnavailable
                                             type: string
                                         type: object
+                                      enableHealthCheckHttp10:
+                                        description: EnableHealthCheckHttp10 is a
+                                          toggle for adding HTTP1.0 support to Envoy
+                                          health-check
+                                        type: boolean
                                       envoyCommandLineArgs:
                                         description: Envoy command line arguments
                                         properties:

controllers/tests/kafkacluster_controller_envoy_test.go

@@ -562,6 +562,8 @@ staticResources:
           - name: envoy.filters.http.router
             typedConfig:
               '@type': type.googleapis.com/envoy.extensions.filters.http.router.v3.Router
+          httpProtocolOptions:
+            acceptHttp10: true
           routeConfig:
             name: local
             virtualHosts:
@@ -810,6 +812,8 @@ staticResources:
           - name: envoy.filters.http.router
             typedConfig:
               '@type': type.googleapis.com/envoy.extensions.filters.http.router.v3.Router
+          httpProtocolOptions:
+            acceptHttp10: true
           routeConfig:
             name: local
             virtualHosts:

controllers/tests/kafkacluster_controller_test.go

@@ -291,6 +291,7 @@ var _ = Describe("KafkaCluster with two config external listener", func() {
 
 		kafkaCluster = createMinimalKafkaClusterCR(fmt.Sprintf("kafkacluster-%d", count), namespace)
 		kafkaCluster.Spec.ListenersConfig.ExternalListeners[0].HostnameOverride = ""
+		kafkaCluster.Spec.EnvoyConfig.EnableHealthCheckHttp10 = true
 		testExternalListener := kafkaCluster.Spec.ListenersConfig.ExternalListeners[0]
 		testExternalListener.Config = &v1beta1.Config{
 			DefaultIngressConfig: "az2",

pkg/resources/envoy/configmap.go

@@ -170,6 +170,11 @@ func generateEnvoyHealthCheckListener(ingressConfig v1beta1.IngressConfig, log l
 			},
 		},
 	}
+	if ingressConfig.EnvoyConfig.EnableHealthCheckHttp10 {
+		healthCheckFilter.HttpProtocolOptions = &envoycore.Http1ProtocolOptions{
+			AcceptHttp_10: true,
+		}
+	}
 	pbstHealthCheckFilter, err := anypb.New(healthCheckFilter)
 	if err != nil {
 		log.Error(err, "could not marshall envoy healthCheckFilter config")