@Override
        public void onConnect(BinaryLogClient client) {
            // Set up the MDC logging context for this thread ...
            taskContext.configureLoggingContext("binlog");

            // The event row number will be used when processing the first event ...
            LOGGER.info("Connected to MySQL binlog at {}:{}, starting at {}", connectorConfig.hostname(),
                    connectorConfig.port(), offsetContext);
        }
Wraps the specified exception in a {@link DebeziumException}, ensuring that all useful state is captured inside
the new exception's message.

@param error the exception; may not be null
@return the wrapped Kafka Connect exception
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java