Strimzi / Kafka Connect 找不到我的插件

Question

我正在使用 Strimzi、Kafka、Kafka Connect 和自定义连接器插件，紧随 this docs。

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

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

Failed to find any class that implements Connector and which name matches org.company.MySourceConnector

我知道原因：它没有找到插件（一个 jar 文件）。但是如果我进入 kafka-connect pod，我可以在正确的（我想）位置看到 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 文件已损坏。

Strimzi / Kafka Connect 找不到我的插件

Strimzi / Kafka Connect does not find my plugin

apache-kafka

apache-kafka-connect

strimzi