パッケージ org.springframework.kafka.core.reactive

クラス ReactiveKafkaProducerTemplate<K,V>

java.lang.ObjectSE
org.springframework.kafka.core.reactive.ReactiveKafkaProducerTemplate<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
AutoCloseableSE, DisposableBean
public class ReactiveKafkaProducerTemplate<K,V> extends ObjectSE implements AutoCloseableSE, DisposableBean
リアクティブ kafka プロデューサー操作の実装。
導入:
2.3.0
作成者:
Mark Norkin, Adrian Chlebosz

  • コンストラクターの詳細

    • ReactiveKafkaProducerTemplate

      public ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions)

    • ReactiveKafkaProducerTemplate

      public ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K,V> senderOptions, RecordMessageConverter messageConverter)

    • ReactiveKafkaProducerTemplate

      public ReactiveKafkaProducerTemplate(reactor.kafka.sender.KafkaSender<K,V> sender)

    • ReactiveKafkaProducerTemplate

      public ReactiveKafkaProducerTemplate(reactor.kafka.sender.KafkaSender<K,V> sender, RecordMessageConverter messageConverter)

  • メソッドの詳細

    • sendTransactionally

      public <T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> sendTransactionally(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records)

    • sendTransactionally

      public <T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> sendTransactionally(reactor.kafka.sender.SenderRecord<K,V,T> record)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(StringSE topic, V value)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(StringSE topic, K key, V value)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(StringSE topic, int partition, K key, V value)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(StringSE topic, int partition, long timestamp, K key, V value)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(StringSE topic, Message<?> message)

    • send

      public reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<VoidSE>> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)

    • send

      public <T> reactor.core.publisher.Mono<reactor.kafka.sender.SenderResult<T>> send(reactor.kafka.sender.SenderRecord<K,V,T> record)

    • send

      public <T> reactor.core.publisher.Flux<reactor.kafka.sender.SenderResult<T>> send(org.reactivestreams.Publisher<? extends reactor.kafka.sender.SenderRecord<K,V,T>> records)

    • partitionsFromProducerFor

      public reactor.core.publisher.Flux<org.apache.kafka.common.PartitionInfo> partitionsFromProducerFor(StringSE topic)

    • metricsFromProducer

      public reactor.core.publisher.Flux<reactor.util.function.Tuple2<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>> metricsFromProducer()

    • doOnProducer

      public <T> reactor.core.publisher.Mono<T> doOnProducer(FunctionSE<org.apache.kafka.clients.producer.Producer<K,V>,? extends T> action)

    • transactionManager

      public reactor.kafka.sender.TransactionManager transactionManager()

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean の destroy 

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close