close

open suspend override fun close(hadNonzeroRecords: Boolean, streamFailure: StreamProcessingFailed?)