@VisibleForTesting
    public boolean getDebeziumStarted() {
        return debeziumStarted;
    }
Safely and gracefully stop the Debezium engine.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/debezium/DebeziumSourceFunction.java