public class AsyncProducer<K,V> extends Object implements ProducerActions<K,V>
Constructor and Description |
---|
AsyncProducer(Properties producerProps,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valSerializer) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<org.apache.kafka.clients.producer.RecordMetadata> |
apply(org.apache.kafka.clients.producer.ProducerRecord<K,V> record) |
void |
close() |
public AsyncProducer(Properties producerProps, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valSerializer)
public CompletableFuture<org.apache.kafka.clients.producer.RecordMetadata> apply(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
apply
in interface Function<org.apache.kafka.clients.producer.ProducerRecord<K,V>,CompletableFuture<org.apache.kafka.clients.producer.RecordMetadata>>
public void close()
close
in interface AutoCloseable
Copyright © 2019 Red Hat. All rights reserved.