如何为mysql数据库创建多个Debezium连接器

Question

我正在为mysql数据库连接多个Debezium连接器，我的配置如下。

sudo docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.5  &
sudo docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:1.5 &
sudo docker run -it --name connect -p 8083:8083 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my_connect_configs -e OFFSET_STORAGE_TOPIC=my_connect_offsets -e STATUS_STORAGE_TOPIC=my_connect_statuses --link zookeeper:zookeeper --link kafka:kafka debezium/connect:1.5 &
sudo docker run -it --name connect1 -p 8084:8084 -e GROUP_ID=1 -e CONFIG_STORAGE_TOPIC=my_connect_configs -e OFFSET_STORAGE_TOPIC=my_connect_offsets -e STATUS_STORAGE_TOPIC=my_connect_statuses --link zookeeper:zookeeper --link kafka:kafka debezium/connect:1.5 &

但当我字符串运行第二个连接器时。。。出现以下错误。

ERRO[0000] error waiting for container: context canceled 

有人能帮我吗。

Answer 1

您没有运行任何连接器，只运行用于工人的容器。

一个Kafka Connect工作程序可以用于通过端口8083 上的HTTP服务器提交多个连接器任务

---

关于显示的命令，您不需要多个容器，除非您试图创建Connect工作集群

为了做到这一点，他们需要相同的主题和相同的组id。

您还需要-p 8084:8083，因为您没有更改服务器端口。此外，您可以使用docker run -d，而不是使用&，但使用Docker Compose在这里更有意义