我正在使用Strimzi
、Kafka
和Kafka 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
如何配置Strimzi
或Kafka Connect
查找我的插件?
我用尽了我所有的资源。如果有人能对此有所了解,我将不胜感激。