refactor: bump operator-go to 0.12-dev (#115)

* refactor: bump domain to kubedoop.dev

* refactor: bump operator-go to 0.12-dev

Author: lwpk110

.github/ISSUE_TEMPLATE/feature_request.yml

@@ -6,7 +6,7 @@ body:
   - type: markdown
     attributes:
       value: |
-        First, check out our [Collaboration Guide](https://zncdata.dev/docs/developer-manual/collaboration)
+        First, check out our [Collaboration Guide](https://kubedoop.dev/docs/developer-manual/collaboration)
         Please provide a searchable summary of the issue in the title above ⬆️.
   - type: dropdown
     attributes:
@@ -27,4 +27,4 @@ body:
   - type: textarea
     attributes:
       label: Motivation 🔦
-      description: What are you trying to accomplish? How has the lack of this feature affected you? Providing context helps us come up with a solution that is more useful in the real world.
+      description: What are you trying to accomplish? How has the lack of this feature affected you? Providing context helps us come up with a solution that is more useful in the real world.

PROJECT

@@ -2,7 +2,7 @@
 # This file is used to track the info used to scaffold your project
 # and allow the plugins properly work.
 # More info: https://book.kubebuilder.io/reference/project-config.html
-domain: zncdata.dev
+domain: kubedoop.dev
 layout:
 - go.kubebuilder.io/v4
 projectName: kafka-operator
@@ -12,7 +12,7 @@ resources:
     crdVersion: v1
     namespaced: true
   controller: true
-  domain: zncdata.dev
+  domain: kubedoop.dev
   group: kafka
   kind: KafkaCluster
   path: github.com/zncdatadev/kafka-operator/api/v1alpha1

README.md

@@ -65,7 +65,7 @@ Kubedoop built-in operators:
 
 ## Contributing
 
-If you'd like to contribute to Kubedoop, please refer to our [Contributing Guide](https://zncdata.dev/docs/developer-manual/collaboration) for more information.
+If you'd like to contribute to Kubedoop, please refer to our [Contributing Guide](https://kubedoop.dev/docs/developer-manual/collaboration) for more information.
 We welcome contributions of all kinds, including but not limited to code, documentation, and use cases.
 
 ## License

api/v1alpha1/groupversion_info.go

@@ -16,15 +16,15 @@ limitations under the License.
 
 // Package v1alpha1 contains API Schema definitions for the kafka v1alpha1 API group
 // +kubebuilder:object:generate=true
-// +groupName=kafka.zncdata.dev
+// +groupName=kafka.kubedoop.dev
 package v1alpha1
 
 import (
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"sigs.k8s.io/controller-runtime/pkg/scheme"
 )
 
-const GroupName = "kafka.zncdata.dev"
+const GroupName = "kafka.kubedoop.dev"
 
 var (
 	// GroupVersion is group version used to register these objects

cmd/main.go

@@ -125,7 +125,7 @@ func main() {
 		HealthProbeBindAddress: probeAddr,
 		LeaderElection:         enableLeaderElection,
 		WebhookServer:          webhookServer,
-		LeaderElectionID:       "6e8ac606.zncdata.dev",
+		LeaderElectionID:       "6e8ac606.kubedoop.dev",
 		// LeaderElectionReleaseOnCancel defines if the leader should step down voluntarily
 		// when the Manager ends. This requires the binary to immediately end when the
 		// Manager is stopped, otherwise, this setting is unsafe. Setting this significantly

config/crd/bases/kafka.zncdata.dev_kafkaclusters.yaml config/crd/bases/kafka.kubedoop.dev_kafkaclusters.yaml

@@ -3,10 +3,10 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   annotations:
-    controller-gen.kubebuilder.io/version: v0.16.1
-  name: kafkaclusters.kafka.zncdata.dev
+    controller-gen.kubebuilder.io/version: v0.16.5
+  name: kafkaclusters.kafka.kubedoop.dev
 spec:
-  group: kafka.zncdata.dev
+  group: kafka.kubedoop.dev
   names:
     kind: KafkaCluster
     listKind: KafkaClusterList

config/crd/kustomization.yaml

@@ -2,7 +2,7 @@
 # since it depends on service name and namespace that are out of this kustomize package.
 # It should be run by config/default
 resources:
-- bases/kafka.zncdata.dev_kafkaclusters.yaml
+- bases/kafka.kubedoop.dev_kafkaclusters.yaml
 #+kubebuilder:scaffold:crdkustomizeresource
 
 patches:

config/crd/patches/cainjection_in_kafkaclusters.yaml

@@ -4,4 +4,4 @@ kind: CustomResourceDefinition
 metadata:
   annotations:
     cert-manager.io/inject-ca-from: CERTIFICATE_NAMESPACE/CERTIFICATE_NAME
-  name: kafkaclusters.kafka.zncdata.dev
+  name: kafkaclusters.kafka.kubedoop.dev

config/crd/patches/webhook_in_kafkaclusters.yaml

@@ -2,7 +2,7 @@
 apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
-  name: kafkaclusters.kafka.zncdata.dev
+  name: kafkaclusters.kafka.kubedoop.dev
 spec:
   conversion:
     strategy: Webhook

config/rbac/kafkacluster_editor_role.yaml

@@ -12,7 +12,7 @@ metadata:
   name: kafkacluster-editor-role
 rules:
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters
   verbs:
@@ -24,7 +24,7 @@ rules:
   - update
   - watch
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters/status
   verbs:

config/rbac/kafkacluster_viewer_role.yaml

@@ -12,15 +12,15 @@ metadata:
   name: kafkacluster-viewer-role
 rules:
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters
   verbs:
   - get
   - list
   - watch
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters/status
   verbs:

config/rbac/role.yaml

@@ -5,9 +5,11 @@ metadata:
   name: manager-role
 rules:
 - apiGroups:
-  - apps
+  - ""
   resources:
-  - statefulsets
+  - configmaps
+  - serviceaccounts
+  - services
   verbs:
   - create
   - delete
@@ -19,27 +21,25 @@ rules:
 - apiGroups:
   - ""
   resources:
-  - configmaps
-  - serviceaccounts
-  - services
+  - pods
   verbs:
-  - create
-  - delete
   - get
   - list
-  - patch
-  - update
   - watch
 - apiGroups:
-  - ""
+  - apps
   resources:
-  - pods
+  - statefulsets
   verbs:
+  - create
+  - delete
   - get
   - list
+  - patch
+  - update
   - watch
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters
   verbs:
@@ -51,13 +51,13 @@ rules:
   - update
   - watch
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters/finalizers
   verbs:
   - update
 - apiGroups:
-  - kafka.zncdata.dev
+  - kafka.kubedoop.dev
   resources:
   - kafkaclusters/status
   verbs:

config/samples/kafka_v1alpha1_kafkacluster.yaml

@@ -1,4 +1,4 @@
-apiVersion: kafka.zncdata.dev/v1alpha1
+apiVersion: kafka.kubedoop.dev/v1alpha1
 kind: KafkaCluster
 metadata:
   labels:

go.mod

@@ -8,7 +8,7 @@ require (
 	github.com/go-logr/logr v1.4.2
 	github.com/onsi/ginkgo/v2 v2.21.0
 	github.com/onsi/gomega v1.35.1
-	github.com/zncdatadev/operator-go v0.11.2
+	github.com/zncdatadev/operator-go v0.11.3-0.20241120112858-dcdca6c6cd44
 	golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56
 	k8s.io/api v0.31.2
 	k8s.io/apimachinery v0.31.2

go.sum

@@ -136,8 +136,8 @@ github.com/x448/float16 v0.8.4 h1:qLwI1I70+NjRFUR3zs1JPUCgaCXSh3SW62uAKT1mSBM=
 github.com/x448/float16 v0.8.4/go.mod h1:14CWIYCyZA/cWjXOioeEpHeN/83MdbZDRQHoFcYsOfg=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
-github.com/zncdatadev/operator-go v0.11.2 h1:/3ti+26D9w38gZV2eQLIz62mPe45em3Ej8iePoSj/04=
-github.com/zncdatadev/operator-go v0.11.2/go.mod h1:Thc0Jo5LuXnwrb73shfI63PKlxC+7cGq7SClzo3Y5qI=
+github.com/zncdatadev/operator-go v0.11.3-0.20241120112858-dcdca6c6cd44 h1:wxxTwfas5UAX46FoinIC/ZmGc+dlk5I+1cT3McypY+4=
+github.com/zncdatadev/operator-go v0.11.3-0.20241120112858-dcdca6c6cd44/go.mod h1:9QGIaH5gTDgpv0kftcGkBGqCIj7cboC5ZMES9fZy4XI=
 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.53.0 h1:4K4tsIXefpVJtvA/8srF4V4y0akAoPHkIslgAkjixJA=
 go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.53.0/go.mod h1:jjdQuTGVsXV4vSs+CJ2qYDeDPf9yIJV23qlIzBm73Vg=
 go.opentelemetry.io/otel v1.28.0 h1:/SqNcYk+idO0CxKEUOtKQClMK/MimZihKYMruSMViUo=

internal/controller/container/kafka.go

@@ -173,7 +173,7 @@ func (d *KafkaContainerBuilder) Command() []string {
 }
 
 // CommandArgs command args
-// ex: export NODE_PORT=$(cat /zncdata/tmp/kafka_nodepor
+// ex: export NODE_PORT=$(cat /kubedoop/tmp/kafka_nodepor
 func (d *KafkaContainerBuilder) CommandArgs() []string {
 	listenerConfig, err := common.GetKafkaListenerConfig(d.namespace, d.KafkaTlsSecurity, d.groupSvcName)
 	if err != nil {

internal/controller/kafkacluster_controller.go

@@ -36,9 +36,9 @@ type KafkaClusterReconciler struct {
 	Log    logr.Logger
 }
 
-// +kubebuilder:rbac:groups=kafka.zncdata.dev,resources=kafkaclusters,verbs=get;list;watch;create;update;patch;delete
-// +kubebuilder:rbac:groups=kafka.zncdata.dev,resources=kafkaclusters/status,verbs=get;update;patch
-// +kubebuilder:rbac:groups=kafka.zncdata.dev,resources=kafkaclusters/finalizers,verbs=update
+// +kubebuilder:rbac:groups=kafka.kubedoop.dev,resources=kafkaclusters,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups=kafka.kubedoop.dev,resources=kafkaclusters/status,verbs=get;update;patch
+// +kubebuilder:rbac:groups=kafka.kubedoop.dev,resources=kafkaclusters/finalizers,verbs=update
 // +kubebuilder:rbac:groups=apps,resources=statefulsets,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=core,resources=configmaps,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=core,resources=serviceaccounts,verbs=get;list;watch;create;update;patch;delete

internal/controller/vector.go

@@ -51,7 +51,7 @@ func ExtendConfigMapByVector(ctx context.Context, params VectorConfigParams, dat
 	if err != nil {
 		vectorLogger.Error(errors.Wrap(err, "error creating vector YAML"), "failed to create vector YAML")
 	} else {
-		data[builder.VectorConfigFile] = vectorYaml
+		data[builder.VectorConfigFileName] = vectorYaml
 	}
 }
 

internal/util/secret.go

@@ -40,7 +40,7 @@ func (s *SecretVolumeBuilder) Build() corev1.Volume {
 					Spec: corev1.PersistentVolumeClaimSpec{
 						AccessModes: []corev1.PersistentVolumeAccessMode{corev1.ReadWriteOnce},
 						StorageClassName: func() *string {
-							cs := "secrets.zncdata.dev"
+							cs := "secrets.kubedoop.dev"
 							return &cs
 						}(),
 						VolumeMode: func() *corev1.PersistentVolumeMode { v := corev1.PersistentVolumeFilesystem; return &v }(),

test/e2e/default/kafka.yaml

@@ -1,4 +1,4 @@
-apiVersion: kafka.zncdata.dev/v1alpha1
+apiVersion: kafka.kubedoop.dev/v1alpha1
 kind: KafkaCluster
 metadata:
   labels:

test/e2e/setup/zookeeper.yaml

@@ -1,4 +1,4 @@
-apiVersion: zookeeper.zncdata.dev/v1alpha1
+apiVersion: zookeeper.kubedoop.dev/v1alpha1
 kind: ZookeeperCluster
 metadata:
   name: zookeepercluster-sample
@@ -18,17 +18,8 @@ spec:
               max: "800m"
             memory:
               limit: "2Gi"
-          logging:
-            zookeeperCluster:
-              loggers:
-                test:
-                  level: DEBUG
-              console:
-                level: INFO
-              file:
-                level: INFO
 ---
-apiVersion: zookeeper.zncdata.dev/v1alpha1
+apiVersion: zookeeper.kubedoop.dev/v1alpha1
 kind: ZookeeperZnode
 metadata:
   labels:
@@ -41,4 +32,3 @@ metadata:
 spec:
   clusterRef:
     name: zookeepercluster-sample
-

test/e2e/vector/kafka.yaml

@@ -1,4 +1,4 @@
-apiVersion: kafka.zncdata.dev/v1alpha1
+apiVersion: kafka.kubedoop.dev/v1alpha1
 kind: KafkaCluster
 metadata:
   labels: