所以我使用kafka-connect-bigquery
连接器
是否可以在";主题";?
例如,我有两个主题:
mysql.database.table1
mysql.database.table2
我想立即将其添加到连接器:
"topics": "mysql.database.*"
感谢
通过用topics.regex
替换topics
属性,可以将基于Kafka主题的regex列入白名单。
Ex
"topics.regex":"mysql.database.*"