DataflowTemplates debezium连接器问题

Question

我指的是使用debezium连接器执行mysql(安装在本地机器上)到pubsub数据流的this文档。

我的属性文件如下所示

databaseName=testdb 
databaseUsername=root 
databaseAddress=localhost 
databasePort=3306 
gcpProject=GCP_project_name 
databasePassword=password 
whitelistedTables=instance-name.testdb.testtab 
singleTopicMode=true 
gcpPubsubTopicPrefix=debeziumTest 
databaseManagementSystem=mysql

我已经在pubsub中创建了名为"debeziumTest“的主题。

但问题是，当我运行sudo mvn exec:java -pl cdc-embedded-connector -Dexec.args="/path/to/properties-file"时

，它运行时没有任何错误：

​

但是没有数据上传到pubsub。

Answer 1

根据文档，会将表更新推送到与此格式匹配的主题-${PREFIX}${DB_INSTANCE}表{.$}表{.$}

在您的情况下，我认为您应该创建一个名称为"debeziumTestinstance-name.testdb.testtab“的主题。

根据我在您共享的日志中看到的警告，这可能不是唯一的问题。

Answer 2

问题似乎出在你的whitelistedTables上。

根据文档，您应该使用${instance}.${database}.${table}，对于给定的示例，它应该是whitelistedTables=testdb.databaseName.testTab (如果testTab是您的表名)