0

我正在使用StrimziKafkaKafka Connect自定义连接器插件,遵循此文档

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

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

找不到任何实现 Connector 且名称与 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/. (该文件由 srimzi 在部署期间创建)

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

如何配置StrimziKafka Connect查找我的插件?

我用尽了我所有的资源。如果有人能对此有所了解,我将不胜感激。

4

1 回答 1

0

我发现jar文件已损坏。

于 2021-12-13T12:23:16.230 回答