启动Kafka Connect Debezium

Question

我在这里设置了融合平台

STEP 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

STEP 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

STEP 3

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

STEP 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而不是tarball安装Confluent。然后，您可以更轻松地升级和安装组件。例如，Confluent Hub allows you to install Debezium。

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

也许可以参考Running and Configuring Connectors上的文档来提供帮助，但需要使用mysql Debezium options在您自己的属性文件中创建与源相关的属性

---

我也建议您获取最新的Debezium版本