@Override
    public String getTargetTopic(RowData element) {
        if (multipleSink) {
            try {
                // Extract the index '0' as the raw data is determined by the Raw format:
                // The Raw format allows to read and write raw (byte based) values as a single column
                return jsonDynamicSchemaFormat.parse(element.getBinary(0), topicPattern);
            } catch (Exception e) {
                // Ignore the parse error and it will return the default topic final.
                LOG.warn("parse dynamic topic error", e);
            }
        }
        return topic;
    }
Serialize for list it is used for multiple sink scenes when a record contains mulitple real records.

@param consumedRow The consumeRow
@param timestamp The timestamp
@return List of ProducerRecord
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java