open static fun <K : Any, V : Any> createShared(: Vertx, : String, : Properties): KafkaProducer<K, V>open static fun <K : Any, V : Any> createShared(: Vertx, : String, : MutableMap<String, String>): KafkaProducer<K, V>
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
vertx - Vert.x instance to use
name - the producer name to identify it
config - Kafka producer configuration
Return
an instance of the KafkaProducer
open static fun <K : Any, V : Any> createShared(: Vertx, : String, : MutableMap<String, String>, : Class<K>, : Class<V>): KafkaProducer<K, V>open static fun <K : Any, V : Any> createShared(: Vertx, : String, : Properties, : Class<K>, : Class<V>): KafkaProducer<K, V>
Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
vertx - Vert.x instance to use
name - the producer name to identify it
config - Kafka producer configuration
keyType - class type for the key serialization
valueType - class type for the value serialization
Return
an instance of the KafkaProducer