我已经在我的kafka connect连接器中安装了运行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?
发布于 2021-10-30 19:40:11
我们需要在安装后重新启动kafka connect吗?
是的,JVM在(重新)启动之前不会获得新的插件
https://stackoverflow.com/questions/69780544
复制相似问题