xtdb-kafka/xtdb.api.log/Kafka

Kafka

object Kafka

Types

Link copied to clipboard
@Serializable
@SerialName(value = "!Kafka")
data class Factory(val bootstrapServers: String, val txTopic: String, val filesTopic: String, var autoCreateTopics: Boolean = true, var txPollDuration: Duration = Duration.ofSeconds(1), var filePollDuration: Duration = Duration.ofSeconds(5), var propertiesMap: Map<String, String> = emptyMap(), var propertiesFile: Path? = null) : Log.Factory

Used to set configuration options for Kafka as an XTDB Transaction Log.

Functions

Link copied to clipboard
@JvmStatic
fun kafka(bootstrapServers: String, txTopic: String, filesTopic: String): Kafka.Factory