xtdb-kafka/xtdb.kafka.connectsrc/RecordIndexer

RecordIndexer

interface RecordIndexer : AutoCloseable

Inheritors

Types

Link copied to clipboard
interface Factory
Link copied to clipboard

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
abstract suspend fun indexRecords(records: List<SinkRecord>, txIndexer: TxIndexer)
Generated by Dokka
© 2026 Copyright