在Google BigQuery接收器连接器中,如果autoCreateTables属性为true,则GCP会在主题名称字段中创建BigQuery表。如果autoCreateTables为false,那么我们应该在GCP中手动创建以主题名称作为表名的表。如果我们想要不同于主题名称的表名称,该怎么办?
https://docs.confluent.io/kafka-connect-bigquery/current/kafka_connect_bigquery_config.html
您可以使用RegexRouter
转换,例如在主题到达接收器之前对其进行重命名。
https://docs.confluent.io/platform/current/connect/transforms/regexrouter.html