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

Question

我是kafka的初学者。 在这里，我正在尝试在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的一些博客文章，介绍如何配置它们

。