indexRecords

open suspend override fun indexRecords(records: List<SinkRecord>, txIndexer: TxIndexer)