mysql - 如何访问 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 的一些博客文章，了解如何配置它们