版本 "kafka.strimzi.io/v1beta2" 中没有匹配的种类"KafkaConnect"

Question

我正在尝试使用Strimzi创建kafka-connect集群，遇到以下错误

unable to recognize "kafka-connect.yaml": no matches for kind "KafkaConnect" in 
version "kafka.strimzi.io/v1beta2"

这是kafka-connect。我有:

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
 name: kafka-connect
 namespace: connect
 annotations:
   strimzi.io/use-connector-resources: "true"
spec:
 version: 2.4.0
 replicas: 1
 bootstrapServers: host:port
 tls:
   trustedCertificates:
     - secretName: connectorsecret
       certificate: cert
 config:
   group.id: o
   offset.storage.topic: strimzi-connect-cluster-offsets
   config.storage.topic: strimzi-connect-cluster-configs
   status.storage.topic: strimzi-connect-cluster-status
   sasl.mechanism: scram-sha-256
   security.protocol: SASL_SSL
   secretName: connectorsecret
   sasl.jaas.config: org.apache.kafka.common.security.scram.ScramLoginModule required username=username password=password

然后我试图通过kubectl apply -f kafka-connect.yaml应用配置

是否有必要使用Strimzi或我做错了什么来创建资源?

Answer 1

我认为有两种可能性:

1. 您没有安装CRD资源
2. 您正在使用的Strimzi版本太旧，不支持v1beta2 API

判断你正在尝试使用Kafka 2.4.0，我猜第二个选项更有可能。如果您ŕeally想要这样做，您应该确保使用文档，示例和您使用的Strimzi版本的所有内容-它们应该使用较旧的api (v1alpha1或v1beta1)之一。

但一般来说，我将强建议您使用最新版本的Strimzi，而不是几年前的版本。

---

还有一点:如果你想为Kafka Connect集群配置SASL身份验证，你应该在自定义资源的.spec.authentication部分进行配置，而不是在.spec.config中。