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

ClusterFactory

@Serializable

@SerialName(value = "!Kafka")

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

Constructors

ClusterFactory

@JvmOverloads

constructor(bootstrapServers: String, pollDuration: Duration = Duration.ofSeconds(1), propertiesMap: Map<String, String> = emptyMap(), propertiesFile: Path? = null, schemaRegistryUrl: String? = null, groupId: String = "xtdb", coroutineContext: CoroutineContext = Dispatchers.Default)