我在这里搭了个汇合平台
第一步
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步
我把这个jar放在里面了 /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 现在我可以在哪里修改与源代码相关的属性？如何启动连接器？
1条答案
按热度按时间nkoocmlb1#
首先，我建议通过apt或yum安装confluent，而不是tarballs。然后您可以更轻松地升级和安装组件。例如，confluent hub允许您安装debezium。
/usr/local/confluent/bin包括两个运行kafka connect的脚本。参考有关运行和配置连接器的文档可能会有所帮助，但与源代码相关的属性需要使用mysql debezium选项在您自己的属性文件中创建
我还建议您获得最新的debezium版本