使用Strimzi创建KafkaConnect集群时遇到资源识别错误求助

出现unable to recognize "kafka-connect.yaml": no matches for kind "KafkaConnect" in version "kafka.strimzi.io/v1beta2"错误，核心原因是Kubernetes集群未安装对应版本的Strimzi自定义资源定义（CRD），或CRD与Strimzi Operator版本不匹配。以下是具体排查和修复步骤：

1. 检查Strimzi CRD是否已安装 #

先确认集群中是否存在KafkaConnect对应的CRD：

kubectl get crd kafkaconnects.kafka.strimzi.io

若返回NotFound，说明你遗漏了安装Strimzi CRD这个关键前置步骤——Strimzi提供的所有Kafka相关自定义资源（如Kafka、KafkaConnect）都依赖CRD才能被Kubernetes识别。

2. 安装对应版本的Strimzi CRD与Operator #

你使用的apiVersion是kafka.strimzi.io/v1beta2，需安装匹配该版本的Strimzi组件：

• 执行以下命令安装对应版本的Strimzi集群Operator（以0.20.1版本为例，该版本兼容v1beta2）：

kubectl apply -f https://github.com/strimzi/strimzi-kafka-operator/releases/download/0.20.1/strimzi-cluster-operator-0.20.1.yaml

注意：需确保Operator版本与apiVersion匹配，v1beta2对应Strimzi 0.19.x至0.25.x版本范围。

3. 配置文件的后续优化（非当前错误原因，但需修正） #

当前错误解决后，你的配置还有几处需要调整以保证正常运行：

• 将bootstrapServers: host:port替换为实际的Kafka集群引导地址，例如Strimzi部署的Kafka集群地址通常为<cluster-name>-kafka-bootstrap:9093（TLS连接场景）。
• sasl.jaas.config中的用户名和密码为明文硬编码，建议通过已指定的connectorsecret Secret引用，避免敏感信息泄露。
• group.id: o过于简略，建议修改为更具辨识度的名称，如connect-cluster-group。

内容的提问来源于stack exchange，提问作者flowAlong