vertx / io.vertx.kafka.client.producer / KafkaProducer / create

create

open static fun <K : Any, V : Any> create(vertx: Vertx, producer: Producer<K, V>): KafkaProducer<K, V>

Create a new KafkaProducer instance from a native Producer.

Parameters

vertx - Vert.x instance to use

producer - the Kafka producer to wrap

Return
an instance of the KafkaProducer

open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, String>): KafkaProducer<K, V>
open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties): KafkaProducer<K, V>

Create a new KafkaProducer instance

Parameters

vertx - Vert.x instance to use

config - Kafka producer configuration

Return
an instance of the KafkaProducer

open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, String>, keyType: Class<K>, valueType: Class<V>): KafkaProducer<K, V>
open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties, keyType: Class<K>, valueType: Class<V>): KafkaProducer<K, V>

Create a new KafkaProducer instance

Parameters

vertx - Vert.x instance to use

config - Kafka producer configuration

keyType - class type for the key serialization

valueType - class type for the value serialization

Return
an instance of the KafkaProducer