Strimzi / Kafka Connect找不到我的插件

Question

我正在使用Strimzi，Kafka，Kafka Connect和一个自定义连接器插件，遵循this docs。

部署工作正常，Kafka Connect工作正常，我可以使用它的RESTFUL API。

但是连接器没有创建。这是错误消息：

未能找到实现连接器且名称与org.company.MySourceConnector匹配的任何类

我知道原因:它找不到插件(一个jar文件)。但是如果我进入卡夫卡-连接荚，我可以看到右边的jar文件：/opt/kafka/plugins/my-source-connector/my-source-connector.jar。

此外，我运行cat /tmp/strimzi-connect.properties并看到插件路径：plugin.path=/opt/kafka/plugins/。(该文件由strimzi在部署期间创建)

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: kafka-connect
  annotations:
    strimzi.io/use-connector-resources: "true"
spec:
  replicas: 1
  bootstrapServers: kafka-kafka-bootstrap:9092
  image: "{{ .Values.image.repository }}:{{ .Values.image.tag }}"
  config:
    group.id: connect-cluster
    ...

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
  name: my-connector
  labels:
    strimzi.io/cluster: kafka-connect
spec:
  class: org.company.MySourceConnector
  tasksMax: 1
  config:
    topic: my-topic
    name: my-connector

如何配置Strimzi或Kafka Connect以找到我的插件？

我用尽了所有的资源。如果有人能对此有所了解，我会非常感激的。

Answer 1

我发现jar文件被破坏了。