如何在JDBCSink连接器中配置配置单元jdbc uber jar

Question

我正在尝试使用hive jdbc uber jar并配置jdbc接收器连接器。

但是连接器抛出错误：

[2022-08-31 00:21:21,583] INFO Unable to connect to database on attempt 1/3. Will retry in 10000 ms. (io.confluent.connect.jdbc.util.CachedConnectionProvider)
java.sql.SQLException: **No suitable driver** found for **jdbc:hive2**://XX.XX.XX.XX:10002/test;auth=noSasl;transportMode=http;httpPath=cliservice

配置

    {
      "name": "connector_schema_test_v01",
      "config": {
        "value.converter.schema.registry.url": "http://schema-registry:8081",
        "key.converter.schema.registry.url": "http://schema-registry:8081",
        "name": "connector_schema_test_v01",
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "1",
        "key.converter": "io.confluent.connect.avro.AvroConverter",
        "value.converter": "io.confluent.connect.avro.AvroConverter",
        "topics": "topic_schema_test_v05",
        "connection.url": "jdbc:hive2://XX.XX.XX.XX:10002/test;auth=noSasl;transportMode=http;httpPath=cliservice",
        "connection.user": "",
        "connection.password": "",
        "insert.mode": "upsert",
        "delete.enabled": "true",
        "table.name.format": "delta_try_v1_2",
        "pk.mode": "record_key",
        "pk.fields": "K1, K2",
        "auto.create": "true",
        "auto.evolve": "true"
      }
    }

驱动程序位于路径中：/usr/share/confluent-hub-components/confluentinc-kafka-connect-jdbc/lib

我已经重新启动连接器，但同样的错误。我认为驱动程序类名必须在某些属性中设置。

知道吗？

Answer 1

hive-jdbc-uber-jar项目创建于2014年，现在附带以下警告：

当我在2014年第一次创建这个项目时，Hive项目没有生成一个“独立”jar，它可靠地包含了成功创建JDBC连接所需的所有依赖项。从那时起，社区解决了许多（如果不是全部）早期问题。到今天为止，Hive的最新版本发布的“独立”jar使这个项目几乎过时。您可以使用maven获取官方的Hive独立jar。

也许您可以像下面这样使用Hive，这将解决您的问题:

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-jdbc</artifactId>
    <version>YOUR VERSION OF HIVE</version>
    <classifier>standalone</classifier>
</dependency>

Answer 2

jdbc接收器连接器没有实现配置单元方言，因此您无法使用该连接器

https://github.com/confluentinc/kafka-connect-jdbc/tree/master/src/main/java/io/confluent/connect/jdbc/dialect