Add e2e tests

Author: amuraru

.github/actions/kind-create/action.yaml

@@ -46,12 +46,12 @@ runs:
       chmod 600 $kubeconfig_path
       echo "kubeconfig=$(echo $kubeconfig_path)" >> $GITHUB_OUTPUT
     shell: bash
-  
+
   - name: Install cloud-provider-kind
     id: cloud-provider-kind
     run: |
       echo "Install cloud-provider-kind"
       go install sigs.k8s.io/cloud-provider-kind@latest
-      kubectl label node e2e-kind-control-plane node.kubernetes.io/exclude-from-external-load-balancers- 
+      kubectl label node e2e-kind-control-plane node.kubernetes.io/exclude-from-external-load-balancers-
       ~/go/bin/cloud-provider-kind &
     shell: bash

.github/workflows/codeql-analysis.yml

@@ -60,17 +60,17 @@ jobs:
       run: |
         # Build main module
         go build ./...
-        
+
         # Build api module
         cd api
         go build ./...
         cd ..
-        
+
         # Build properties module
         cd properties
         go build ./...
         cd ..
-        
+
         # Build main binary
         go build -o bin/manager main.go
 

.github/workflows/e2e-test.yaml

@@ -11,7 +11,7 @@ concurrency:
   cancel-in-progress: true
 
 env:
-  REPOSITORY: koperator_e2e_test  
+  REPOSITORY: koperator_e2e_test
 
 jobs:
   build:
@@ -20,7 +20,7 @@ jobs:
     steps:
       - name: Checkout code
         uses: actions/checkout@v5
-        
+
       - name: Clean workspace
         run: |
           # Remove any existing go.work files to ensure clean module resolution
@@ -35,7 +35,7 @@ jobs:
         uses: azure/setup-helm@v4
         with:
           version: '3.19.0'
-          
+
       - name: Clean Go module cache
         run: |
           # Clean any existing Go module cache to avoid conflicts
@@ -47,13 +47,17 @@ jobs:
           # Ensure proper permissions
           chmod -R 755 ~/go/pkg/mod
           chmod -R 755 ~/.cache/go-build
-          
-      # Enable Tmate Session if you'd like to Debut the E2E Kind Cluster
-      # - name: Setup tmate session
-      #   uses: mxschmitt/action-tmate@v3
-      #   with:
-      #     detached: true
-      
+
+      # Enable Tmate Session to debug the E2E Kind Cluster
+      # Only activates when re-running the workflow in debug mode
+      - name: Setup tmate session
+        if: ${{ runner.debug == '1' }}
+        continue-on-error: true
+        uses: mxschmitt/action-tmate@v3
+        with:
+          detached: true
+          limit-access-to-actor: true
+
       - name: Build docker image
         run: |
           IMG=$REPOSITORY:$GITHUB_SHA make docker-build
@@ -75,11 +79,13 @@ jobs:
           cd properties && go mod download && cd ..
           cd tests/e2e && go mod download && cd ../..
 
-          
+
       - name: Run E2E tests
         env:
            KUBECONFIG: ${{ steps.setup-kind.outputs.kubeconfig }}
         run: |
           # Clean any existing go.work files to avoid workspace conflicts
           rm -f go.work go.work.sum
           IMG_E2E=$REPOSITORY:$GITHUB_SHA make test-e2e
+
+

ADOPTERS.md

@@ -1,8 +1,8 @@
 # Adopters
  This is a list of production adopters of Banzai Cloud's Kafka Operator (in alphabetical order):
- 
+
 - Adobe Experience Platform is using the Kafka Operator to enable consistent deployment, dynamic scaling, smooth upgrades and auto-balancing in our cross-cloud Kafka infrastructure. Adobe is also contributing to the open source version of the operator.
 
 - [Banzai Cloud](https://banzaicloud.com) is using the Kafka Operator to provision, configure and manage a secure, resilient and autoscaling production ready Apache Kafka for customers.
 
-- AffirmedNetworks is looking to use Kafka Operator to provision, configure and manage life cycle of production ready Apache Kafka. One of the use cases we are looking at, is to use Kafka to manage Event Data/Detail Record that gets generated in our applications. 
+- AffirmedNetworks is looking to use Kafka Operator to provision, configure and manage life cycle of production ready Apache Kafka. One of the use cases we are looking at, is to use Kafka to manage Event Data/Detail Record that gets generated in our applications.

api/assets/kafka/kraft-controller-healthcheck.sh

@@ -32,7 +32,7 @@ MATCHING_METRIC=$(curl -s "$JMX_ENDPOINT" | grep "^${METRIC_PREFIX}" | awk '$2 =
 
 # If it's not empty, it means we found a metric with a value of 1.0.
 if [ -n "$MATCHING_METRIC" ]; then
-    # Determine the state of the controller using the last field name of the metric 
+    # Determine the state of the controller using the last field name of the metric
     # Possible values are leader, candidate, voted, follower, unattached, observer
     STATE=$(echo "$MATCHING_METRIC" | rev | cut -d'_' -f1 | rev)
 

api/v1beta1/common_types.go

@@ -199,12 +199,6 @@ const (
 	PKIBackendK8sCSR PKIBackend = "k8s-csr"
 )
 
-// IstioControlPlaneReference is a reference to the IstioControlPlane resource.
-type IstioControlPlaneReference struct {
-	Name      string `json:"name"`
-	Namespace string `json:"namespace"`
-}
-
 // GracefulActionState holds information about GracefulAction State
 type GracefulActionState struct {
 	// CruiseControlState holds the information about graceful action state

api/v1beta1/kafkacluster_types.go

@@ -187,10 +187,8 @@ type KafkaClusterSpec struct {
 	// Selector for broker pods that need to be recycled/reconciled
 	TaintedBrokersSelector *metav1.LabelSelector `json:"taintedBrokersSelector,omitempty"`
 	// +kubebuilder:validation:Enum=envoy;contour;istioingress
-	// IngressController specifies the type of the ingress controller to be used for external listeners. The `istioingress` ingress controller type requires the `spec.istioControlPlane` field to be populated as well.
+	// IngressController specifies the type of the ingress controller to be used for external listeners.
 	IngressController string `json:"ingressController,omitempty"`
-	// IstioControlPlane is a reference to the IstioControlPlane resource for envoy configuration. It must be specified if istio ingress is used.
-	IstioControlPlane *IstioControlPlaneReference `json:"istioControlPlane,omitempty"`
 	// If true OneBrokerPerNode ensures that each kafka broker will be placed on a different node unless a custom
 	// Affinity definition overrides this behavior
 	OneBrokerPerNode bool `json:"oneBrokerPerNode"`

api/v1beta1/zz_generated.deepcopy.go

@@ -20944,27 +20944,12 @@ spec:
                 type: boolean
               ingressController:
                 description: IngressController specifies the type of the ingress controller
-                  to be used for external listeners. The `istioingress` ingress controller
-                  type requires the `spec.istioControlPlane` field to be populated
-                  as well.
+                  to be used for external listeners.
                 enum:
                 - envoy
                 - contour
                 - istioingress
                 type: string
-              istioControlPlane:
-                description: IstioControlPlane is a reference to the IstioControlPlane
-                  resource for envoy configuration. It must be specified if istio
-                  ingress is used.
-                properties:
-                  name:
-                    type: string
-                  namespace:
-                    type: string
-                required:
-                - name
-                - namespace
-                type: object
               istioIngressConfig:
                 description: IstioIngressConfig defines the config for the Istio Ingress
                   Controller

charts/kafka-operator/crds/kafkaclusters.yaml

@@ -20944,27 +20944,12 @@ spec:
                 type: boolean
               ingressController:
                 description: IngressController specifies the type of the ingress controller
-                  to be used for external listeners. The `istioingress` ingress controller
-                  type requires the `spec.istioControlPlane` field to be populated
-                  as well.
+                  to be used for external listeners.
                 enum:
                 - envoy
                 - contour
                 - istioingress
                 type: string
-              istioControlPlane:
-                description: IstioControlPlane is a reference to the IstioControlPlane
-                  resource for envoy configuration. It must be specified if istio
-                  ingress is used.
-                properties:
-                  name:
-                    type: string
-                  namespace:
-                    type: string
-                required:
-                - name
-                - namespace
-                type: object
               istioIngressConfig:
                 description: IstioIngressConfig defines the config for the Istio Ingress
                   Controller