【问题标题】:Kafka connect could not find JdbcSinkConnector even if it's installed即使安装了 Kafka connect 也找不到 JdbcSinkConnector
【发布时间】: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


    【解决方案1】:

    安装后需要重启kafka connect吗?

    是的,JVM 在(重新)启动之前不会选择新插件

    【讨论】:

      猜你喜欢
      • 2014-10-26
      • 1970-01-01
      • 1970-01-01
      • 2021-02-13
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-04-16
      • 2020-07-10
      相关资源
      最近更新 更多