vertx / io.vertx.kotlin.kafka.client.common / kafkaClientOptionsOf

kafkaClientOptionsOf

fun kafkaClientOptionsOf(config: Map<String, Any>? = null, tracePeerAddress: String? = null, tracingPolicy: TracingPolicy? = null): KafkaClientOptions

A function providing a DSL for building io.vertx.kafka.client.common.KafkaClientOptions objects.

Generic KafkaClient options.

Parameters

config - Set the Kafka config.

tracePeerAddress - Set the Kafka address to show in trace tags. Or leave it unset to automatically pick up bootstrap server from config instead.

tracingPolicy - Set the Kafka tracing policy.