如何连接 MySQL 到 Kafka 集群

How to connect MySQL to Kafka cluster

我正在尝试学习 kafka 技术,我想在我的电脑中设置一个小型管道,它将从 mysql 获取数据并将它们解析到 kafka 集群中。

对于我所做的一项小型研究,我发现最好的方法是 KAFKA CONNECTOR。 有人可以提供有关如何实现上述逻辑的提示或信息吗?

最简单的方法是使用 JDBC 源连接器将数据从 MySQL 服务器提取到 Kafka 主题以进行进一步处理。请找到 link 到 Confluent JDBC source connector。请查看连接器提供的各种配置,以便更好地调整您的数据以进行后续处理。