【发布时间】:2021-12-15 05:13:02
【问题描述】:
我已经在我的 kafka 连接连接器中安装了运行 confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:10.2.5 的 JDBC 连接器,但是当我尝试使用实现新接收器时出现以下错误:找不到任何实现连接器且名称与 io.confluent 匹配的类。 connect.jdbc.JdbcSinkConnector
我正在尝试使用的接收器
{
"name": "jdbc-sink-connector",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
"tasks.max": "1",
"topics": "my_topic",
"connection.url": "jdbc:postgresql://ip:port/postgres",
"connection.user": "postgres",
"connection.password": "PASSWORD",
"auto.create": "true"
}
}
我正在使用 confluentinc/cp-kafka-connect:6.1.0 图像
如果我使用 confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:10.2.5 构建映像并使用此映像,它就可以工作。 所以看起来我们需要在安装后重新启动 kafka connect ?
【问题讨论】:
标签: apache-kafka apache-kafka-connect confluent-platform