使用带有配置提供程序的 Debezium 源连接器 - Amazon Managed Streaming for Apache Kafka

使用带有配置提供程序的 Debezium 源连接器

此示例演示了如何将 Debezium MySQL 连接器插件与兼容 MySQL 的 Amazon Aurora 数据库一起用作来源。在此示例中，我们还设置了开源 AWS Secrets Manager 配置提供程序来对 AWS Secrets Manager 中的数据库凭证进行外部化。要了解有关配置提供程序的更多信息，请参阅教程：使用配置提供程序将敏感信息外部化。

重要

Debezium MySQL 连接器插件仅支持一项任务，不使用 Amazon MSK Connect 的自动扩缩容量模式。您应该改为使用预置容量模式，并在连接器配置中将 workerCount 设置为 1。要了解有关 MSK Connect 容量模式的更多信息，请参阅了解连接器容量。

有关包含详细步骤的 Debezium 连接器示例，请参阅 Introducing Amazon MSK Connect - Stream Data to and from Your Apache Kafka Clusters Using Managed Connectors。