1

我有一个用例,我必须通过 Kafka 连接捕获 AWS RDS MySQL 数据库中的数据更改并将其发布到 Kafka 主题上。对于 Kafka,我使用 AWS Managed Streaming for Apache Kafka (MSK) 服务。我已经创建了主题。我只剩下连接器部分,以便消费者在使用主题时可以看到消息/事件。

我的问题是,如何创建 Kafka Connect 连接器来监控 AWS Managed Streaming for Apache Kafka (MSK) 集群中的 AWS RDS MySQL 数据库?

我正在按照Debezium 0.9 教程使用 Docker 容器来实现此目的,用于 Kafka 和 AWS RDS 实例。我想使用 AWS Managed Streaming for Apache Kafka (MSK) 而不是 Docker 容器来实现这一点。我只想在消费者端使用 Docker 容器。

这甚至可能吗,还是我必须为 AWS ECS 或 AWS EKS 做?

4

0 回答 0