KafkaCluster

class KafkaCluster(val kafkaConfigMap: KafkaConfigMap, val schemaRegistryUrl: String? = null, coroutineContext: CoroutineContext = Dispatchers.Default) : Remote

Constructors

constructor(kafkaConfigMap: KafkaConfigMap, schemaRegistryUrl: String? = null, coroutineContext: CoroutineContext = Dispatchers.Default)

@Serializable

@SerialName(value = "!Kafka")

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

@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

val kafkaConfigMap: KafkaConfigMap

val producer: KafkaProducer<Unit, ByteArray>

val scope: CoroutineScope

open override fun close()