Kafka

data class Kafka(val brokers: Array<String>? = null, val topic: String? = null, val schemaRegistryUrl: String? = null, val params: Map<String, Any>? = null)

Represents a Kafka configuration.

Constructors

constructor(brokers: Array<String>? = null, topic: String? = null, schemaRegistryUrl: String? = null, params: Map<String, Any>? = null)

An array of Kafka brokers. Default is null.

Additional parameters for Kafka. Default is null.

The URL of the Schema Registry. Default is null.

val topic: String? = null

The Kafka topic. Default is null.