invoke

open suspend operator override fun invoke(message: Reserved<CheckpointMessage>, totalRecords: Long, totalBytes: Long, totalRejectedRecords: Long)