eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkCheckConnector.java [137:149]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void put(List<ConnectRecord> sinkRecords) {
        if (sinkRecords == null || sinkRecords.isEmpty() || sinkRecords.get(0) == null) {
            if (log.isDebugEnabled()) {
                log.debug("[{}] got sink records are none", this.getClass());
            }
            return;
        }
        try {
            queue.put(sinkRecords);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java [138:151]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void put(List<ConnectRecord> sinkRecords) {
        if (sinkRecords == null || sinkRecords.isEmpty() || sinkRecords.get(0) == null) {
            if (log.isDebugEnabled()) {
                log.debug("[{}] got sink records are none", this.getClass());
            }
            return;
        }
        try {
            queue.put(sinkRecords);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }

    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -