xtdb-kafka/xtdb.api.log/KafkaCluster

KafkaCluster

class KafkaCluster(val kafkaConfigMap: KafkaConfigMap, pollDuration: Duration, val schemaRegistryUrl: String? = null, val transactionalIdPrefix: String? = null, groupId: String = "xtdb", coroutineContext: CoroutineContext = Dispatchers.Default) : Remote

Constructors

KafkaCluster

constructor(kafkaConfigMap: KafkaConfigMap, pollDuration: Duration, schemaRegistryUrl: String? = null, transactionalIdPrefix: String? = null, groupId: String = "xtdb", coroutineContext: CoroutineContext = Dispatchers.Default)

Types

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 transactionalIdPrefix: String? = null, var groupId: String = "xtdb", var coroutineContext: CoroutineContext = Dispatchers.Default) : Remote.Factory<KafkaCluster>

LogFactory

@Serializable

@SerialName(value = "!Kafka")

data class LogFactory @JvmOverloads constructor(val cluster: RemoteAlias, val topic: String, var replicaCluster: RemoteAlias = cluster, var replicaTopic: String = "-replica", var autoCreateTopic: Boolean = true, var epoch: Int = 0) : Log.Factory

Properties

kafkaConfigMap

val kafkaConfigMap: KafkaConfigMap

producer

val producer: KafkaProducer<Unit?, ByteArray?>

schemaRegistryUrl

val schemaRegistryUrl: String?

scope

val scope: CoroutineScope

transactionalIdPrefix

val transactionalIdPrefix: String?

Functions

open override fun close()