public MessageQueueZoneSink getMqZoneSink() {
        return mqZoneSink;
    }
get message queue zone sink

@return the zone sink
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java