クラスの使用
org.springframework.kafka.requestreply.RequestReplyFuture
org.springframework.kafka.requestreply 内の RequestReplyFuture 使用
修飾子と型メソッド説明ReplyingKafkaOperations.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record) リクエストを送信し、デフォルトのタイムアウトで応答を受信します。ReplyingKafkaOperations.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record, DurationSE replyTimeout) リクエストを送信し、返信を受け取ります。ReplyingKafkaTemplate.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record) ReplyingKafkaTemplate.sendAndReceive
(org.apache.kafka.clients.producer.ProducerRecord<K, V> record, DurationSE replyTimeout) 修飾子と型メソッド説明protected boolean
AggregatingReplyingKafkaTemplate.handleTimeout
(ObjectSE correlationId, RequestReplyFuture<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> future) protected boolean
ReplyingKafkaTemplate.handleTimeout
(ObjectSE correlationId, RequestReplyFuture<K, V, R> future) リクエストがタイムアウトしたことをサブクラスに通知して、状態をクリーンアップし、オプションでフューチャーを完了することができるようにするために使用されます。