我是卡夫卡的初学者。在这里，我试图在卡夫卡中构建实时数据管道。我有位于远程的数据库。我真的不明白如何访问数据库和数据库像实时一样不断更新。我读到关于 Debezium [https://debezium.io/docs/tutorial/]但在整个教程中，他们没有展示任何从实时远程数据库中提取数据的示例。我有MySQL数据库。
最佳答案
理想情况下，Debezium 应该尽可能靠近数据库服务器运行
但是如果您查看教程，如果指定了远程 docker 容器，则可以将主机名替换为与您的环境匹配的任何内容
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"tasks.max": "1",
"database.hostname": "... Your server here... ",
"database.port": "3306",
另一个选项是 Kafka Connect JDBC 连接器，您可以查看 Confluence 的一些博客文章，了解如何配置它们
关于mysql - 如何在Apache Kafka中访问远程数据库？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/52140036/