无法使用Confluent docker部署Debezium mysql连接器

问题描述 投票:1回答:1

[我试图运行汇合的docker映像以使用Debezium MYSQL连接器启动连接服务,但在运行docker之后无法获取已加载的类。

Docker命令

docker run -d \
    --name=kafka-connect \
    --net=host \
    -e CONNECT_BOOTSTRAP_SERVERS="b-2.<bootstrap_server>.us-east-1.amazonaws.com:9092,b-3.<bootstrap_server>.us-east-1.amazonaws.com:9092,b-1.<bootstrap_server>.us-east-1.amazonaws.com:9092" \
    -e CONNECT_REST_PORT=8083 \
    -e CONNECT_PLUGIN_PATH="/usr/share/java,/tmp/connectors" \
    -e CONNECT_GROUP_ID="quickstart" \
    -e CONNECT_CONFIG_STORAGE_TOPIC="quick-config" \
    -e CONNECT_OFFSET_STORAGE_TOPIC="quick-offsets" \
    -e CONNECT_STATUS_STORAGE_TOPIC="quick-status" \
    -e CONNECT_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \
    -e CONNECT_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \
    -e CONNECT_INTERNAL_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \
    -e CONNECT_INTERNAL_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter" \
    -e CONNECT_REST_ADVERTISED_HOST_NAME="ec2-<public_ip>.compute-1.amazonaws.com" \
    -v /opt/connectors:/tmp/connectors \
    confluentinc/cp-kafka-connect:3.1.2

在卷(-v)中使用的我的实例目录文件如下:

ubuntu@ip-<hostname>:/opt/connectors$ ls
debezium-connect-jdbc

以下命令测试Debezium Mysql驱动程序类是否已加载

curl -s http://ec2-<public_ip>.compute-1.amazonaws.com:8083/connector-plugins | jq .

运行上述命令后,我看不到如下所述的Debezium Mysql连接器类]]

io.debezium.connector.mysql.MySqlConnector

我尝试运行汇合的docker镜像以使用Debezium MYSQL连接器启动连接服务,但是在运行docker之后无法获取已加载的类。 Docker命令docker run -d \ ...

docker apache-kafka-connect confluent-schema-registry confluent-kafka debezium
1个回答
1
投票

您的问题太旧了,Kafka Connect版本:confluentinc/cp-kafka-connect:3.1.2 ships的版本为0.10.1.1,但是Classloading Isolation in Connect仅在0.11.0中实现。

© www.soinside.com 2019 - 2024. All rights reserved.