Flink cdc同步数据时，如何根据表名自动创建Kafka的topic

可以使用 Flink CDC 的动态表名特性和 Kafka 的自动创建 topic 特性来实现根据表名自动创建 Kafka 的 topic。

具体做法是：

1. 在 Flink CDC 中，使用动态表名特性，将表名作为动态参数传递给 Kafka 的 sink。
2. 在 Kafka 中，启用自动创建 topic 特性，当 Kafka 发现有新的 topic 时，会自动创建该 topic。

下面是具体的操作步骤：

1. 在 Flink CDC 中，使用动态表名特性。在 sink 的构造函数中，使用 ${cdc.table} 占位符表示动态表名。例如：

   String topic = "cdc_${cdc.table}";
   Properties properties = new Properties();
   properties.setProperty("bootstrap.servers", "localhost:9092");
   FlinkKafkaProducer<String> kafkaSink = new FlinkKafkaProducer<String>(
       topic,
       new SimpleStringSchema(),
       properties);

2. 在 Kafka 中，启用自动创建 topic 特性。在 Kafka 的配置文件中，设置如下参数：

   auto.create.topics.enable=true

这样，当 Flink CDC 向 Kafka 中写入数据时，如果 Kafka 发现该 topic 不存在，就会自动创建该 topic。

需要注意的是，自动创建 topic 特性可能会带来一些安全隐患，因此在实际生产环境中需要谨慎使用。