xtdb-kafka/xtdb.kafka.connectsrc/KafkaConnectSource/Factory

Factory

@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

Constructors

constructor(remote: RemoteAlias, topic: String, connectConfig: Map<String, String> = emptyMap(), indexer: RecordIndexer.Factory)

Types

class Registration : ExternalSource.Registration<KafkaConnectSource.Factory>

Properties

val connectConfig: Map<String, String>

val indexer: RecordIndexer.Factory

val remote: RemoteAlias

val topic: String

Functions

open override fun open(dbName: String, remotes: Map<RemoteAlias, Remote>, meterRegistry: MeterRegistry?): ExternalSource