public ChangeEventQueue<DataChangeEvent> getQueue() {
        return queue;
    }
A subclass implementation of {@link EventDispatcher}.

<pre>
 1. This class shares one {@link ChangeEventQueue} between multiple readers.
 2. This class override some methods for dispatching {@link HistoryRecord} directly,
    this is useful for downstream to deserialize the {@link HistoryRecord} back.
</pre>
Copy from com.ververica:flink-cdc-base:2.3.0.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/relational/JdbcSourceEventDispatcher.java