Uses of Class
io.vertx.mutiny.kafka.client.producer.KafkaProducer

Packages that use KafkaProducer

Package	Description
io.vertx.mutiny.kafka.client.producer

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

Fields in io.vertx.mutiny.kafka.client.producer with type parameters of type KafkaProducer

Modifier and Type	Field	Description
static final TypeArg<KafkaProducer>	KafkaProducer.__TYPE_ARG

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

Modifier and Type	Method	Description
KafkaProducer<K,V>	KafkaProducer.abortTransactionAndForget()	Variant of abortTransaction() that ignores the result of the operation.
KafkaProducer<K,V>	KafkaProducer.beginTransactionAndForget()	Variant of beginTransaction() that ignores the result of the operation.
KafkaProducer<K,V>	KafkaProducer.commitTransactionAndForget()	Variant of commitTransaction() that ignores the result of the operation.
static <K, V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config)
static <K, V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, Map<String,String> config, Class<K> keyType, Class<V> valueType)
static <K, V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer)
static <K, V> KafkaProducer<K,V>	KafkaProducer.create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer, io.vertx.kafka.client.common.KafkaClientOptions options)
static <K, V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, io.vertx.kafka.client.common.KafkaClientOptions options)
static <K, V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, io.vertx.kafka.client.common.KafkaClientOptions options, Class<K> keyType, Class<V> valueType)
static <K, V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config)
static <K, V> KafkaProducer<K,V>	KafkaProducer.createShared(Vertx vertx, String name, Map<String,String> config, Class<K> keyType, Class<V> valueType)
KafkaProducer<K,V>	KafkaProducer.drainHandler(Runnable handler)
KafkaProducer<K,V>	KafkaProducer.exceptionHandler(Consumer<Throwable> handler)
KafkaProducer<K,V>	KafkaProducer.flushAndForget()	Variant of flush() that ignores the result of the operation.
KafkaProducer<K,V>	KafkaProducer.initTransactionsAndForget()	Variant of initTransactions() that ignores the result of the operation.
static <K, V> KafkaProducer<K,V>	KafkaProducer.newInstance(io.vertx.kafka.client.producer.KafkaProducer arg)
static <K, V> KafkaProducer<K,V>	KafkaProducer.newInstance(io.vertx.kafka.client.producer.KafkaProducer arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)
KafkaProducer<K,V>	KafkaProducer.partitionsForAndForget(String topic)	Variant of partitionsFor(String) that ignores the result of the operation.
KafkaProducer<K,V>	KafkaProducer.sendAndForget(KafkaProducerRecord<K,V> record)	Variant of send(io.vertx.mutiny.kafka.client.producer.KafkaProducerRecord) that ignores the result of the operation.
KafkaProducer<K,V>	KafkaProducer.setWriteQueueMaxSize(int i)