K
- the key type.V
- the value type.public class ReactiveKafkaProducerTemplate<K,V>
extends java.lang.Object
implements java.lang.AutoCloseable, org.springframework.beans.factory.DisposableBean
Constructor and Description |
---|
ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions) |
ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions,
RecordMessageConverter messageConverter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
destroy() |
<T> reactor.core.publisher.Mono<T> |
doOnProducer(java.util.function.Function<org.apache.kafka.clients.producer.Producer<K,V>,? extends T> action) |
reactor.core.publisher.Mono<java.lang.Void> |
flush() |
reactor.core.publisher.Flux<reactor.util.function.Tuple2<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> |
metricsFromProducer() |
reactor.core.publisher.Flux<org.apache.kafka.common.PartitionInfo> |
partitionsFromProducerFor(java.lang.String topic) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record) |
<T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> |
send(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records) |
<T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> |
send(reactor.kafka.sender.SenderRecord<K,V,T> record) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(java.lang.String topic,
int partition,
K key,
V value) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(java.lang.String topic,
int partition,
long timestamp,
K key,
V value) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(java.lang.String topic,
K key,
V value) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(java.lang.String topic,
org.springframework.messaging.Message<?> message) |
reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> |
send(java.lang.String topic,
V value) |
<T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> |
sendTransactionally(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records) |
<T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> |
sendTransactionally(reactor.kafka.sender.SenderRecord<K,V,T> record) |
reactor.kafka.sender.TransactionManager |
transactionManager() |
public ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions)
public ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions, RecordMessageConverter messageConverter)
public <T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> sendTransactionally(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records)
public <T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> sendTransactionally(reactor.kafka.sender.SenderRecord<K,V,T> record)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(java.lang.String topic, V value)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(java.lang.String topic, K key, V value)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(java.lang.String topic, int partition, K key, V value)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(java.lang.String topic, int partition, long timestamp, K key, V value)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(java.lang.String topic, org.springframework.messaging.Message<?> message)
public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<java.lang.Void>> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
public <T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> send(reactor.kafka.sender.SenderRecord<K,V,T> record)
public <T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> send(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records)
public reactor.core.publisher.Mono<java.lang.Void> flush()
public reactor.core.publisher.Flux<org.apache.kafka.common.PartitionInfo> partitionsFromProducerFor(java.lang.String topic)
public reactor.core.publisher.Flux<reactor.util.function.Tuple2<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> metricsFromProducer()
public <T> reactor.core.publisher.Mono<T> doOnProducer(java.util.function.Function<org.apache.kafka.clients.producer.Producer<K,V>,? extends T> action)
public reactor.kafka.sender.TransactionManager transactionManager()
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
public void close()
close
in interface java.lang.AutoCloseable