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

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

Constructors

constructor(cluster: RemoteAlias, topic: String, replicaCluster: RemoteAlias = cluster, replicaTopic: String = "-replica", autoCreateTopic: Boolean = true, epoch: Int = 0)

Properties

autoCreateTopic

var autoCreateTopic: Boolean

val cluster: RemoteAlias

var replicaCluster: RemoteAlias

var replicaTopic: String

val topic: String

Functions

autoCreateTopic

fun autoCreateTopic(autoCreateTopic: Boolean): KafkaCluster.LogFactory

fun epoch(epoch: Int): KafkaCluster.LogFactory

openReadOnlyReplicaLog

open override fun openReadOnlyReplicaLog(remotes: Map<RemoteAlias, Remote>, partitions: Int): ReadOnlyLog<ReplicaMessage>

openReadOnlySourceLog

open override fun openReadOnlySourceLog(remotes: Map<RemoteAlias, Remote>, partitions: Int): ReadOnlyLog<SourceMessage>

open override fun openReplicaLog(remotes: Map<RemoteAlias, Remote>, partitions: Int): Log<ReplicaMessage>

open override fun openSourceLog(remotes: Map<RemoteAlias, Remote>, partitions: Int): Log<SourceMessage>

fun replicaCluster(replicaCluster: RemoteAlias): KafkaCluster.LogFactory

fun replicaTopic(replicaTopic: String): KafkaCluster.LogFactory

open override fun writeTo(dbConfig: DatabaseConfig.Builder)