当使用AWS MSK连接器(Debezium Postgres连接器)时,我目前面临以下问题
0509fac07b9701a23错误测试jdbc:postgresql://debezium-cdc.fac07b9701a2.ap-south-1.rds.amazonaws.com:5432/ecommerce与用户“debezium”(io.debezium.connector.postgresql.PostgresConnector:133)的连接失败
我已经在EC2上使用Kafka客户端测试了AWS连接器,我能够生成和使用消息。我还设置了AWS S3 Sink连接器,这也是工作。
我已经双倍地检查了AWS的安全组配置,我能够从EC2连接到它。
我不知道是什么导致了这个问题。
这是连接器的配置
connector.class=io.debezium.connector.postgresql.PostgresConnector
tasks.max=1
database.hostname=debezium-cdc.fac07b9701a2.ap-south-1.rds.amazonaws.com
database.port=5432
database.dbname=ecommerce
database.user=debezium
database.password=password
database.history.kafka.bootstrap.servers=b-2.awskafkatutorialclust.awskaf.c4.kafka.ap-south-1.amazonaws.com:9094,b1.awskafkatutorialclust.awskaf.c4.kafka.ap-south-1.amazonaws.com:9094,b-3.awskafkatutorialclust.awskaf.c4.kafka.ap-south-1.amazonaws.com:9094
database.server.id=1
database.server.name=debezium-cdc
database.whitelist=ecommerce
database.history.kafka.topic=dbhistory.ecommerce
include.schema.changes=true
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
发布于 2022-02-01 10:51:34
您需要设置AWS数据库可公开访问:否。因为您的AWS是在一个专用网络(VPC)中,并且它不能连接到公共数据库(请阅读更多信息:https://docs.aws.amazon.com/vpc/latest/userguide/how-it-works.html)。
请尝试更改您的RDS数据库Postgres公开访问:否。并再次创建MSK连接。(确保AWS RDS数据库与AWS MSK相同的VPC、安全组。)
无论如何,如果您想连接您的专用AWS数据库,您需要处理堡垒主机(请阅读更多信息:https://aws.amazon.com/premiumsupport/knowledge-center/rds-connect-ec2-bastion-host/)。
https://stackoverflow.com/questions/70765601
复制相似问题