xtdb-kafka/xtdb.kafka.connectsrc/KafkaConnectSource

KafkaConnectSource

class KafkaConnectSource : ExternalSource

Types

@Serializable

@SerialName(value = "!KafkaConnect")

data class Factory(val remote: RemoteAlias, val topic: String, val connectConfig: Map<String, String> = emptyMap(), val indexer: RecordIndexer.Factory) : ExternalSource.Factory

Functions

open override fun close()

onPartitionAssigned

open suspend override fun onPartitionAssigned(partition: Int, afterToken: ExternalSourceToken?, txIndexer: TxIndexer)