Uses of Interface
io.vertx.kafka.client.producer.KafkaProducer

Packages that use KafkaProducer

Package	Description
io.vertx.kafka.client.producer
io.vertx.reactivex.kafka.client.producer
io.vertx.rxjava3.kafka.client.producer

Uses of KafkaProducer in io.vertx.kafka.client.producer

Methods in io.vertx.kafka.client.producer that return KafkaProducer

Modifier and Type	Method	Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config, Class<K> keyType, Class<V> valueType)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Create a new KafkaProducer instance
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer)	Create a new KafkaProducer instance from a native Producer.
static <K,V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer, KafkaClientOptions options)	Create a new KafkaProducer instance from a native Producer.
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, KafkaClientOptions options)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, KafkaClientOptions options, Class<K> keyType, Class<V> valueType)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, KafkaClientOptions options, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config, Class<K> keyType, Class<V> valueType)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config, Class<K> keyType, Class<V> valueType)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
static <K,V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)	Get or create a KafkaProducer instance which shares its stream with any other KafkaProducer created with the same name
KafkaProducer<K,V>	KafkaProducer.drainHandler(Handler<Void> handler)
KafkaProducer<K,V>	KafkaProducer.exceptionHandler(Handler<Throwable> handler)
KafkaProducer<K,V>	KafkaProducer.setWriteQueueMaxSize(int i)

Uses of KafkaProducer in io.vertx.reactivex.kafka.client.producer

Methods in io.vertx.reactivex.kafka.client.producer that return KafkaProducer

Modifier and Type	Method	Description
KafkaProducer	KafkaProducer.getDelegate()

Methods in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducer

Modifier and Type	Method	Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg)
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.reactivex.kafka.client.producer with parameters of type KafkaProducer

Modifier	Constructor	Description
	KafkaProducer(KafkaProducer delegate)

Uses of KafkaProducer in io.vertx.rxjava3.kafka.client.producer

Methods in io.vertx.rxjava3.kafka.client.producer that return KafkaProducer

Modifier and Type	Method	Description
KafkaProducer	KafkaProducer.getDelegate()

Methods in io.vertx.rxjava3.kafka.client.producer with parameters of type KafkaProducer

Modifier and Type	Method	Description
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg)
static <K,V> KafkaProducer<K,V>	KafkaProducer.newInstance(KafkaProducer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)

Constructors in io.vertx.rxjava3.kafka.client.producer with parameters of type KafkaProducer

Modifier	Constructor	Description
	KafkaProducer(KafkaProducer delegate)