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, var termEpoch: Int = 0) : Log.Factory

Constructors

LogFactory

@JvmOverloads

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

Properties

autoCreateTopic

var autoCreateTopic: Boolean

cluster

val cluster: RemoteAlias

epoch

var epoch: Int

replicaCluster

var replicaCluster: RemoteAlias

replicaTopic

var replicaTopic: String

termEpoch

var termEpoch: Int

Declares that the leader-election counter behind this log has been reset, so that terms from before the reset still order below terms from after it. Bump it — never lower it — whenever that happens; a node that finds its own term already fenced on the replica log refuses to lead and names this setting. See LeaderTerm.

topic

val topic: String

Functions

autoCreateTopic

fun autoCreateTopic(autoCreateTopic: Boolean): KafkaCluster.LogFactory

epoch

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>

openReplicaLog

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

openSourceLog

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

replicaCluster

fun replicaCluster(replicaCluster: RemoteAlias): KafkaCluster.LogFactory

replicaTopic

fun replicaTopic(replicaTopic: String): KafkaCluster.LogFactory

termEpoch

fun termEpoch(termEpoch: Int): KafkaCluster.LogFactory

writeTo

open override fun writeTo(dbConfig: DatabaseConfig.Builder)