xtdb-kafka/xtdb.api.log/KafkaCluster/ClusterFactory

ClusterFactory

@Serializable

@SerialName(value = "!Kafka")

data class ClusterFactory @JvmOverloads constructor(val bootstrapServers: String, var propertiesMap: Map<String, String> = emptyMap(), var propertiesFile: Path? = null, var schemaRegistryUrl: String? = null, var coroutineContext: CoroutineContext = Dispatchers.Default) : Remote.Factory<KafkaCluster>

Constructors

ClusterFactory

@JvmOverloads

constructor(bootstrapServers: String, propertiesMap: Map<String, String> = emptyMap(), propertiesFile: Path? = null, schemaRegistryUrl: String? = null, coroutineContext: CoroutineContext = Dispatchers.Default)