Put method still processing after sink connector is paused

Kafka Connect
1

Hi,
We are writing a sink connector and using Kafka connect-api 2.5.1 with confluent 5.5. We observed that even though the connector is PAUSED (both connector and task is in PAUSED state) but put method is still not paused and keeps on running. The test logger that we have put keeps appearing in the log.

I am trying to understand whether we are missing anything here or this is by design.

To test the flow we kept the put method very basic.

    @Override
    public void put(Collection<SinkRecord> records) {
        recordCounter = 0;
        if (!records.isEmpty()) {
            recordCounter ++;
        }
        logger.info("Put method :::: recordCounter :: " + recordCounter);
    }
2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.