我有一个用例,我必须将所有 MySQL 数据库数据推送到 Kafka 主题。现在,我知道我可以使用 Kafka 连接器启动并运行它,但我想了解它是如何在不使用连接器的情况下在内部工作的。在我的 Spring Boot 项目中,我已经创建了一个 Kafka Producer 文件,我在其中设置了所有配置,创建了一个 Producer 记录等等。
有没有人尝试过这种方法?任何人都可以对此有所了解吗?
我有一个用例,我必须将所有 MySQL 数据库数据推送到 Kafka 主题。现在,我知道我可以使用 Kafka 连接器启动并运行它,但我想了解它是如何在不使用连接器的情况下在内部工作的。在我的 Spring Boot 项目中,我已经创建了一个 Kafka Producer 文件,我在其中设置了所有配置,创建了一个 Producer 记录等等。
有没有人尝试过这种方法?任何人都可以对此有所了解吗?