クラスの使用
org.springframework.kafka.requestreply.RequestReplyFuture
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, @Nullable DurationSE replyTimeout) 型 RequestReplyFuture のパラメーターを持つ org.springframework.kafka.requestreply のメソッド修飾子と型メソッド説明protected booleanAggregatingReplyingKafkaTemplate.handleTimeout(ObjectSE correlationId, RequestReplyFuture<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> future) protected booleanReplyingKafkaTemplate.handleTimeout(ObjectSE correlationId, RequestReplyFuture<K, V, R> future) リクエストがタイムアウトしたことをサブクラスに通知して、状態をクリーンアップし、オプションでフューチャーを完了することができるようにするために使用されます。