kafka connect jdbc接收器连接器:未找到类装入器

6psbrbz9  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(301)

使用confluent docker all-in-one package,标签5.4.1;我正在努力使jdbc接收器连接器启动并运行。
启动以下连接器时:

{
  "name": "mySink",
  "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
  "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  "topics": [
    "myTopic"
  ],
  "connection.url": "jdbc:sqlserver://sqlserver:1433;databaseName=myDB",
  "connection.user": "user",
  "connection.password": "**********",
  "dialect.name": "SqlServerDatabaseDialect",
  "insert.mode": "insert",
  "table.name.format": "TableSink",
  "pk.mode": "kafka",
  "fields.whitelist": [
    "offset",
    "value"
  ],
  "auto.create": "true"
}

(某些属性已编辑)
我从connect容器中得到以下异常: ERROR Plugin class loader for connector: 'io.confluent.connect.jdbc.JdbcSinkConnector' was not found. 对于connect,我有以下环境变量: CONNECT_PLUGIN_PATH: "/usr/share/java,/usr/share/confluent-hub-components" 如果我在集装箱登记,我有: /usr/share/java/kafka-connect-jdbc 包含以下文件:

./jtds-1.3.1.jar
./common-utils-5.4.0.jar
./slf4j-api-1.7.26.jar
./kafka-connect-jdbc-5.4.0.jar
./postgresql-9.4.1212.jar
./sqlite-jdbc-3.25.2.jar
./mssql-jdbc-8.2.0.jre8.jar
./mssql-jdbc-8.2.0.jre13.jar
./mssql-jdbc-8.2.0.jre11.jar

我对base connect映像所做的唯一更改是mssqljdbc驱动程序。对于jdbc源连接器来说,这些都可以正常工作。
要求的额外信息:
输出自 curl -s localhost:8083/connector-plugins|jq '.[].class' ```
"io.confluent.connect.activemq.ActiveMQSourceConnector"
"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector"
"io.confluent.connect.gcs.GcsSinkConnector"
"io.confluent.connect.ibm.mq.IbmMQSourceConnector"
"io.confluent.connect.jdbc.JdbcSinkConnector"
"io.confluent.connect.jdbc.JdbcSourceConnector"
"io.confluent.connect.jms.JmsSourceConnector"
"io.confluent.connect.s3.S3SinkConnector"
"io.confluent.connect.storage.tools.SchemaSourceConnector"
"io.confluent.kafka.connect.datagen.DatagenConnector"
"org.apache.kafka.connect.file.FileStreamSinkConnector"
"org.apache.kafka.connect.file.FileStreamSourceConnector"
"org.apache.kafka.connect.mirror.MirrorCheckpointConnector"
"org.apache.kafka.connect.mirror.MirrorHeartbeatConnector"
"org.apache.kafka.connect.mirror.MirrorSourceConnector"

docker编写源:https://github.com/confluentinc/examples/tree/5.4.1-post/cp-all-in-one
图像:

confluentinc/cp-ksql-cli:5.4.1
confluentinc/cp-enterprise-control-center:5.4.1
confluentinc/cp-ksql-server:5.4.1
cnfldemos/cp-server-connect-datagen:0.2.0-5.4.0
confluentinc/cp-kafka-rest:5.4.1
confluentinc/cp-schema-registry:5.4.1
confluentinc/cp-server:5.4.1
confluentinc/cp-zookeeper:5.4.1

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题