apache-kafka - 适用于 RDS Aurora 的 Debezium 连接器

标签 apache-kafka apache-kafka-connect amazon-aurora debezium

我正在尝试将 debezium 与 rds/aurora/一起使用,我在考虑使用哪个连接器来使用 MySQL 连接器,或者还有另一个用于 Aurora 的连接器?另外,我如何将 debezium 连接器(本地主机)连接到远程 aws aurora 数据库?另外,是否有人将 debezium 与 aurora 一起使用来分享一些信息。

此外,我如何配置 debezium 以将我们正在监控的不同表写入不同的 kafka 主题?

问候

最佳答案

创建 AWS Aurora 实例时,您必须在

  • 兼容 MySQL 的 Amazon Aurora
  • 兼容 PostgreSQL 的 Amazon Aurora

基于此,您可以为 Debezium 选择 MySQL 或 Postgres 连接器。 Aurora 没有单独的连接器。

how can i connect debezium connector(localhost) to remote aws aurora db?

您需要使用 database.hostnamedatabase.port 配置连接器

引用 - https://debezium.io/documentation/reference/1.0/connectors/index.html

关于apache-kafka - 适用于 RDS Aurora 的 Debezium 连接器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57686722/

相关文章:

java - 卡夫卡 : ERROR Plugin class loader for connector: 'org.apache.kafka.connect.file.FileStreamSourceConnector' was not found

amazon-web-services - 使用AWS SQS作为Aurora数据库的写入队列提高系统性能是否有效

amazon-web-services - 全局 Aurora 数据库的 CloudFormation 模板

amazon-web-services - 我无法在 AWS Aurora 集群中启用 "Public access"配置

apache-kafka - 卡夫卡消费群正在重新平衡

apache-kafka - 如何部署 Yolean Kubernetes Kafka?

ssl - Kafka Connect 无法通过 SSL 读取 Kafka 主题

ssl - DataStax 接收器连接器 (kafka-connect-dse) 抛出 javax.net.ssl.SSLException : SSLEngine closed already

apache-kafka - kafka + 如何避免磁盘存储不足

apache-kafka - Kafka 消费者因使用未知协议(protocol)反序列化 Avro 消息时出错而失败