如何在Apache Kafka中访问远程数据库？

Question

我是卡夫卡的初学者。在这里，我试图在卡夫卡建立实时数据管道。我有远程位于的数据库。我真的不明白如何访问数据库和数据库不断实时更新。我读了关于debezium [https://debezium.io/docs/tutorial/]但是整个教程他们没有显示任何他们从实时远程数据库中提取数据的例子。我有MySQL数据库。

Answer 1

理想情况下，Debezium应尽可能靠近数据库服务器运行

但是，如果你看一下教程，if指定一个远程docker容器，你可以用你的环境匹配的东西替换主机名

"connector.class":  "io.debezium.connector.mysql.MySqlConnector", 
"tasks.max": "1", 
"database.hostname": "... Your server here... ", 
"database.port": "3306",

另一个选项是Kafka Connect JDBC连接器，您可以看到Confluent的一些博客文章，了解如何配置它们