我正在使用Kafka接收器任务读取Kafka主题的记录。sinktask方法中的put（）是从中获取所有记录的入口点。当前，当连接器启动时，它将把所有未提交的记录收集在一起。我希望worker任务一次获取一条记录。怎么做？

class CustomSinkTask extends SinkTask{

    @Override
        public void put(Collection<SinkRecord> records) {

            System.out.println("Inside put method " );
            if(records != null)
                System.out.println("number of records fetched are:" + records.size());
    }
}