KafkaProducer<K,V> |
KafkaProducer.abortTransactionAndForget() |
|
KafkaProducer<K,V> |
KafkaProducer.beginTransactionAndForget() |
|
KafkaProducer<K,V> |
KafkaProducer.commitTransactionAndForget() |
|
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.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() |
|
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) |
|
KafkaProducer<K,V> |
KafkaProducer.sendAndForget(KafkaProducerRecord<K,V> record) |
|
KafkaProducer<K,V> |
KafkaProducer.setWriteQueueMaxSize(int i) |
|