## 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>` | KafkaProducer.`asStream()`
    `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, 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
    `KafkaWriteStream<K,V>` | KafkaWriteStream.`flush(Handler<Void> completionHandler)` Invoking this method makes all buffered records immediately available to write
    `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.`write(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

Copyright © 2017. All rights reserved.