flink cdc 内置了 mq吗 ？我看怎么能获取主题？

Flink CDC 内置了支持将变更数据发送到消息队列（MQ）的功能，但不直接提供获取主题的方法。要获取主题信息，你可以通过解析 SourceRecord 对象来获取。以下是一个示例代码片段，展示如何从 SourceRecord 中获取主题、数据库和表名：

java
Copy
@Override
public void deserialize(SourceRecord sourceRecord, Collector collector) {
String topic = sourceRecord.topic();
String[] fields = topic.split("\.");
String database = fields[1];
String tableName = fields[2];

Struct struct = (Struct) sourceRecord.value();
// 根据需要解析 Struct 中的字段和值

// 将解析的数据放入 DataChangeInfo 对象并发送给下游处理
DataChangeInfo dataChangeInfo = new DataChangeInfo(database, tableName, /* other fields */);
collector.collect(dataChangeInfo);

}
在上述代码中，sourceRecord.topic() 方法用于获取主题名称，然后使用 String.split() 方法按照.进行拆分，得到数据库名和表名。然后，你可以根据需要解析 Struct 对象中的字段和值，并将解析的数据放入自定义的 DataChangeInfo 对象中，最后发送给下游处理。