搭配組態提供者使用 Debezium 來源連接器 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

搭配組態提供者使用 Debezium 來源連接器

此範例顯示如何使用具有與 MySQL 相容 Amazon Aurora 資料庫的 Debezium MySQL 連接器外掛程式做為來源。在此範例中,我們也會設定開放原始碼 AWS Secrets Manager Config Provider,以在 AWS Secrets Manager中將資料庫憑證外部化。如需有關組態供應商的詳細資訊,請參閱 教學課程:使用組態提供者將敏感資訊外部化

重要

Debezium MySQL 連接器外掛程式僅支援一個任務,不適用於 Amazon MSK Connect 的自動擴展容量模式。您應改用佈建容量模式,並在連接器組態中將 workerCount 設定為等於一。如需有關 MSK Connect 容量模式的詳細資訊,請參閱 了解連接器容量

如需具有詳細步驟的 Debezium 連接器範例,請參閱 Introducing Amazon MSK Connect - Stream Data to and from Your Apache Kafka Clusters Using Managed Connectors