## Uses of Interface
io.vertx.kafka.client.producer.KafkaWriteStream

- Packages that use KafkaWriteStream
  Package | Description
  --- | ---
  io.vertx.kafka.client.producer |

- - ### Uses of KafkaWriteStream in io.vertx.kafka.client.producer

    Methods in io.vertx.kafka.client.producer that return KafkaWriteStream
    Modifier and Type | Method and Description
    --- | ---
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`abortTransaction(Handler<AsyncResult<Void>> handler)` Aborts the ongoing transaction.
    `KafkaWriteStream<K,V>` | KafkaProducer.`asStream()`
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`beginTransaction(Handler<AsyncResult<Void>> handler)` Starts a new kafka transaction.
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`commitTransaction(Handler<AsyncResult<Void>> handler)` Commits the ongoing transaction.
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, KafkaClientOptions options)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, KafkaClientOptions options, Class<K> keyType, Class<V> valueType)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, KafkaClientOptions options, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Map<String,Object> config)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Map<String,Object> config, Class<K> keyType, Class<V> valueType)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Map<String,Object> config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, org.apache.kafka.clients.producer.Producer<K,V> producer)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Properties config)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType)` Create a new KafkaWriteStream instance
    `static <K,V> KafkaWriteStream<K,V>` | KafkaWriteStream.`create(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer)` Create a new KafkaWriteStream instance
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`drainHandler(Handler<Void> handler)`
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`exceptionHandler(Handler<Throwable> handler)`
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`flush(Handler<AsyncResult<Void>> completionHandler)` Invoking this method makes all buffered records immediately available to write
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`initTransactions(Handler<AsyncResult<Void>> handler)` Initializes the underlying kafka transactional producer.
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`partitionsFor(String topic, Handler<AsyncResult<List<org.apache.kafka.common.PartitionInfo>>> handler)` Get the partition metadata for the give topic.
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, Handler<AsyncResult<org.apache.kafka.clients.producer.RecordMetadata>> handler)` Asynchronously write a record to a topic
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`setWriteQueueMaxSize(int i)`

Copyright © 2021 Eclipse. All rights reserved.