trigger OrdFulEvtTrigger on Order_Fulfilment_Event__e (after insert) {
    System.debug('**** In order fulfillment event trigger');
    List<Order_Fulfillment__b> ofbs = new List<Order_Fulfillment__b>();


    // Iterate through each notification.
    for (Order_Fulfilment_Event__e event : Trigger.New) {
        Order_Fulfillment__b ofb = new Order_Fulfillment__b();
        ofb.Order__c  = event.SF_Order_ID__c;
        ofb.SourceSystem__c  = event.SourceSystem__c;
        ofb.TransactionID__c  = event.Transaction_ID__c;
        ofb.TransactionType__c  = event.Transaction_Type__c;
        ofb.TransactionTimestamp__c = event.Transaction_Timestamp__c;
        ofb.Description__c = event.Description__c;
        ofbs.add(ofb);
    }

    System.debug('***** count of big object records to insert: ' + ofbs.size());
    if (ofbs.size() > 0) {
        List<Database.SaveResult> saveResult = database.insertImmediate(ofbs);
        for (Database.SaveResult sr : saveResult) {
            if (!sr.isSuccess()) {
                for(Database.Error err : sr.getErrors()) {
                    System.debug('***The following error has occurred.');
                    System.debug(err.getStatusCode() + ': ' + err.getMessage());
                    System.debug('Account fields that affected this error: ' + err.getFields());
                }
            } else {
                System.debug('***** big object save sucessful');
            }
        }
    }

}