在Flink CDC中消费kafka时如何区分不同record对应是哪个表？

当Flink CDC从MySQL将A库的数据路由到Kafka的topicA，B库的数据路由到topicB时，每个库的数据会被写入不同的topic。在消费Kafka时，可以通过Kafka消费者配置来订阅对应的topic，例如：
订阅topicA来消费A库的数据：

类似地订阅topicB来消费B库的数据：

记录的元数据中通常不包含直接表示表名的信息，因此在消费时，您需要根据订阅的topic来区分数据来自哪个库的哪个表。如果在Flink CDC配置中添加了自定义的元数据信息，可以通过解析消息内容获取这些信息。重启、释放实例等操作可能导致业务中断，建议您提前做好数据备份，并在非业务高峰期时执行该操作