connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java [53:67]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void put(List<ConnectRecord> sinkDataEntries) throws ConnectException {
        try {
            log.info("Hudi Sink Task trying to put()");
            for (ConnectRecord record : sinkDataEntries) {
                log.info("Hudi Sink Task trying to call updater.push()");
                Boolean isSuccess = updater.push(record);
                if (!isSuccess) {
                    log.error("Hudi sink push data error, record:{}", record);
                }
                log.debug("Hudi pushed data : " + record);
            }
        } catch (Exception e) {
            log.error("put sinkDataEntries error, {}", e);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/connector/MqttSinkTask.java [46:60]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void put(List<ConnectRecord> sinkDataEntries) throws ConnectException {
        try {
            log.info("MQTT Sink Task trying to put()");
            for (ConnectRecord record : sinkDataEntries) {
                log.info("MQTT Sink Task trying to call updater.push()");
                Boolean isSuccess = updater.push(record);
                if (!isSuccess) {
                    log.error("mqtt sink push data error, record:{}", record);
                }
                log.debug("mqtt pushed data : " + record);
            }
        } catch (Exception e) {
            log.error("put sinkDataEntries error, {}", e);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -