apache / rocketmq-operator

Apache RocketMQ Operator
https://rocketmq.apache.org/
Apache License 2.0
308 stars 126 forks source link

create topictransfer encounter Failed to list topic with output: The sub command topiclist -c -n 192.168.25.11:9876 not exist. #219

Open victorgkang opened 3 months ago

victorgkang commented 3 months ago

This is my topictransfer.yaml apiVersion: rocketmq.apache.org/v1alpha1 kind: TopicTransfer metadata: annotations: meta.helm.sh/release-name: rocketmq meta.helm.sh/release-namespace: rocketmq labels: app.kubernetes.io/managed-by: Helm name: topictransfer namespace: rocketmq selfLink: /apis/rocketmq.apache.org/v1alpha1/namespaces/rocketmq/topictransfers/topictransfer uid: d9ebc8e4-6a97-4cb3-9fbc-7dc5ee967541 spec: sourceCluster: broker-0 targetCluster: broker-1 topic: TopicTest

After create above topictransfer.yaml, operator encounter 2024-03-31T01:25:16.872Z ERROR controller_topictransfer Failed to list topic with output: The sub command topiclist -c -n 192.168.25.11:9876 not exist. sigs.k8s.io/controller-runtime/pkg/internal/controller.(Controller).Reconcile /go/pkg/mod/sigs.k8s.io/controller-runtime@v0.10.0/pkg/internal/controller/controller.go:114 sigs.k8s.io/controller-runtime/pkg/internal/controller.(Controller).reconcileHandler /go/pkg/mod/sigs.k8s.io/controller-runtime@v0.10.0/pkg/internal/controller/controller.go:311 sigs.k8s.io/controller-runtime/pkg/internal/controller.(Controller).processNextWorkItem /go/pkg/mod/sigs.k8s.io/controller-runtime@v0.10.0/pkg/internal/controller/controller.go:266 sigs.k8s.io/controller-runtime/pkg/internal/controller.(Controller).Start.func2.2 /go/pkg/mod/sigs.k8s.io/controller-runtime@v0.10.0/pkg/internal/controller/controller.go:227

So, I guess under code has bug!!! cmd := exec.Command(cons.BasicCommand, cons.AdminToolDir, topicListCmd)