跳到主要内容

kafka connect

解压文件

下载下面的文件,在你的Linux系统中使用命令tar -xvf clickhouse-sink-connect.tar解压.

启动容器

cd clickhouse-sink-connect

docker compose up

登录到kafka UI

在浏览器访问8089端口会看到你在kafka中的topic。后续会使用debezium连接器捕获数据库的变更数据并将数据读取到kafka,你每有一张表都会在kafka中创建一个topic。

在kafka UI中创建连接器(可选)

可以在UI界面创建连接器,选择你要创建的连接器类型,输入连接器的配置信息创建连接器。在下一章节将详细讲述如何创建连接器。