K8s: Allow connectors to be deployed with operator.

src/go/k8s/api/redpanda/v1alpha1/redpanda_clusterspec_types.go

@@ -37,6 +37,8 @@ type RedpandaClusterSpec struct {
 
 	Console *RedpandaConsole `json:"console,omitempty"`
 
+	Connectors *RedpandaConnectors `json:"connectors,omitempty"`
+
 	Auth *Auth `json:"auth,omitempty"`
 
 	TLS *TLS `json:"tls,omitempty"`
@@ -164,6 +166,17 @@ type ConsoleCreateObj struct {
 	Create bool `json:"create"`
 }
 
+type RedpandaConnectors struct {
+	Enabled *bool `json:"enabled,omitempty"`
+
+	Deployment *ConnectorsCreateObj `json:"deployment,omitempty"`
+	Test       *ConnectorsCreateObj `json:"test,omitempty"`
+}
+
+type ConnectorsCreateObj struct {
+	Create *bool `json:"enabled,omitempty"`
+}
+
 // Auth is a top-level field of the values file
 type Auth struct {
 	SASL *SASL `json:"sasl"`

src/go/k8s/config/crd/bases/cluster.redpanda.com_redpandas.yaml

@@ -161,6 +161,21 @@ spec:
                         type: object
                         x-kubernetes-preserve-unknown-fields: true
                     type: object
+                  connectors:
+                    properties:
+                      deployment:
+                        properties:
+                          enabled:
+                            type: boolean
+                        type: object
+                      enabled:
+                        type: boolean
+                      test:
+                        properties:
+                          enabled:
+                            type: boolean
+                        type: object
+                    type: object
                   console:
                     properties:
                       affinity:

src/go/k8s/internal/controller/redpanda/redpanda_controller.go

@@ -496,7 +496,7 @@ func (r *RedpandaReconciler) helmReleaseRequiresUpdate(ctx context.Context, hr,
 	case !reflect.DeepEqual(hr.GetValues(), hrTemplate.GetValues()):
 		log.Info("values found different")
 		return true
-	case helmChartRequiresUpdate(&hr.Spec.Chart, &hrTemplate.Spec.Chart):
+	case helmChartRequiresUpdate(log, &hr.Spec.Chart, &hrTemplate.Spec.Chart):
 		log.Info("chartTemplate found different")
 		return true
 	case hr.Spec.Interval != hrTemplate.Spec.Interval:
@@ -510,13 +510,13 @@ func (r *RedpandaReconciler) helmReleaseRequiresUpdate(ctx context.Context, hr,
 // helmChartRequiresUpdate compares the v2beta1.HelmChartTemplate of the
 // v2beta1.HelmRelease to the given v1beta2.HelmChart to determine if an
 // update is required.
-func helmChartRequiresUpdate(template, chart *helmv2beta1.HelmChartTemplate) bool {
+func helmChartRequiresUpdate(log logr.Logger, template, chart *helmv2beta1.HelmChartTemplate) bool {
 	switch {
 	case template.Spec.Chart != chart.Spec.Chart:
-		fmt.Println("chart is different")
+		log.Info("chart is different")
 		return true
 	case template.Spec.Version != "" && template.Spec.Version != chart.Spec.Version:
-		fmt.Println("spec version is different")
+		log.Info("spec version is different")
 		return true
 	default:
 		return false

src/go/k8s/tests/e2e-v2/connectors/00-assert-create-redpanda.yaml

@@ -0,0 +1,53 @@
+---
+apiVersion: cluster.redpanda.com/v1alpha1
+kind: Redpanda
+metadata:
+  finalizers:
+    - operator.redpanda.com/finalizer
+  name: redpanda
+spec:
+  chartRef:
+    chartVersion: "5.6.46"
+  clusterSpec:
+    statefulset:
+      replicas: 1
+    connectors:
+      enabled: true
+status:
+  conditions:
+    - message: Redpanda reconciliation succeeded
+      reason: RedpandaClusterDeployed
+      status: "True"
+      type: Ready
+  helmRelease: redpanda
+  helmReleaseReady: true
+  helmRepository: redpanda-repository
+  helmRepositoryReady: true
+---
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: redpanda
+spec:
+  replicas: 1
+status:
+  availableReplicas: 1
+  currentReplicas: 1
+  readyReplicas: 1
+  replicas: 1
+  updatedReplicas: 1
+---
+apiVersion: apps/v1
+kind: pod
+metadata:
+  name: redpanda
+  labels:
+    app.kubernetes.io/component: connectors
+    app.kubernetes.io/instance: redpanda
+status:
+  phase: Running
+---
+apiVersion: kuttl.dev/v1beta1
+kind: TestAssert
+collectors:
+  - command: ../../../hack/get-redpanda-info.sh redpanda ../../_e2e_artifacts_v2

src/go/k8s/tests/e2e-v2/connectors/00-create-redpanda.yaml

@@ -0,0 +1,13 @@
+---
+apiVersion: cluster.redpanda.com/v1alpha1
+kind: Redpanda
+metadata:
+  name: redpanda
+spec:
+  chartRef:
+    chartVersion: "5.6.46"
+  clusterSpec:
+    statefulset:
+      replicas: 1
+    connectors:
+      enabled: true

src/go/k8s/tests/e2e-v2/connectors/01-assert.yaml

@@ -0,0 +1,4 @@
+apiVersion: kuttl.dev/v1beta1
+kind: TestAssert
+collectors:
+- command: ../../../hack/get-redpanda-info.sh redpanda ../../_e2e_artifacts_v2

src/go/k8s/tests/e2e-v2/connectors/01-delete-redpandas.yaml

@@ -0,0 +1,18 @@
+---
+apiVersion: kuttl.dev/v1beta1
+kind: TestStep
+delete:
+  - apiVersion: cluster.redpanda.com/v1alpha1
+    kind: Redpanda
+  - apiVersion: batch/v1
+    kind: Job
+  - apiVersion: v1
+    kind: PersistentVolumeClaim
+  - apiVersion: v1
+    kind: Pod
+    labels:
+      app.kubernetes.io/name: redpanda
+  - apiVersion: v1
+    kind: Service
+    labels:
+      app.kubernetes.io/name: redpanda