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.
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
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
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