我是Kafka的初学者。在这里，我试图建立Kafka实时数据管道。我有一个远程数据库。我真的不知道如何访问数据库和数据库不断更新像实时。我读到了关于debezium的文章[https://debezium.io/docs/tutorial/]但在整个教程中，他们没有展示任何从实时远程数据库中提取数据的示例。我有mysql数据库。
sqserrrh1#
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看到一些关于如何配置它们的博客文章
1条答案
按热度按时间sqserrrh1#
debezium在理想情况下应该尽可能靠近数据库服务器运行
但是如果您查看教程，if指定了一个远程docker容器，您可以用与您的环境匹配的任何内容替换主机名
另一个选项是kafka connect jdbc连接器，您可以通过confluent看到一些关于如何配置它们的博客文章