Starting Kafka Connect Debezium

Question

我在这里设置了融合平台

步骤 1

wget /usr/local http://packages.confluent.io/archive/5.2/confluent-5.2.0-2.11.tar.gz -P ~/Downloads/
tar -zxvf ~/Downloads/confluent-5.2.0-2.11.tar.gz -C ~/Downloads/
sudo mv ~/Downloads/confluent-5.2.0 /usr/local/confluent

步骤 2

我也下载了debizium我的sql jar

wget https://repo1.maven.org/maven2/io/debezium/debezium-connector-mysql/0.9.2.Final/debezium-connector-mysql-0.9.2.Final-plugin.tar.gz

步骤 3

我把这个罐子放在里面/usr/local/confluent/share/java/debezium

步骤 4

我修改了/usr/local/confluent/etc/kafka/connect-standalone.properties与plugin.path=/usr/local/confluent/share/java,/usr/local/confluent/share/java/debezium

现在我可以在哪里修改源相关属性？ 如何启动连接器？

Answer 1

首先，我建议通过APT或YUM而不是压缩包来安装Confluent。然后，您可以更轻松地升级和安装组件。例如，Confluent Hub 允许您安装 Debezium。

/usr/local/confluent/bin包括两个运行Kafka Connect的脚本。

也许参考有关运行和配置连接器的文档会有所帮助，但您的源相关属性需要使用 mysql Debezium 选项在您自己的属性文件中创建

---

我还建议获取最新的Debezium版本