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

Question

我是卡夫卡的初学者。在这里，我试图用kafka构建实时数据管道。我有一个数据库，它位于远程。我真的不明白如何访问数据库，以及如何实时地不断更新数据库。我读过有关debezium [https://debezium.io/docs/tutorial/]的文章，但整个教程都没有展示任何从实时远程数据库中提取数据的示例。我有MySQL数据库。

Answer 1

Debezium最好是尽可能靠近数据库服务器运行

但是，如果您查看本教程，如果指定了远程docker容器，则可以将主机名替换为与您的环境匹配的任何内容

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

另一种选择是Kafka Connect JDBC连接器，您可以在Confluent上看到一些关于如何配置它们的博客文章