クラスの使用
org.springframework.kafka.support.SendResult
SendResult を使用するパッケージ
パッケージ
説明
kafka コアコンポーネントのパッケージ
kafka リスナーのためのパッケージ
リクエスト / 応答セマンティクスのクラスを提供します。
org.springframework.kafka.core 内の SendResult 使用
型 SendResult の引数を持つ型を返す org.springframework.kafka.core のメソッド修飾子と型メソッド説明protected CompletableFutureSE<SendResult<K, V>> KafkaTemplate.doSend(org.apache.kafka.clients.producer.ProducerRecord<K, V> producerRecord, io.micrometer.observation.Observation observation) プロデューサーレコードを送信します。キーまたはパーティションなしで、提供されたトピックにデータを送信します。KafkaOperations.send(StringSE topic, IntegerSE partition, LongSE timestamp, K key, @Nullable V data) 提供されたキーとパーティションを使用して、提供されたトピックにデータを送信します。提供されたキーとパーティションを使用して、提供されたトピックにデータを送信します。提供されたキーを使用して、パーティションなしで、提供されたトピックにデータを送信します。提供されたProducerRecordを送信します。メッセージヘッダーにルーティング情報を含むメッセージを送信します。KafkaOperations.sendDefault(@Nullable V data) キーまたはパーティションなしでデータをデフォルトトピックに送信します。KafkaOperations.sendDefault(IntegerSE partition, LongSE timestamp, K key, @Nullable V data) 提供されたキーとパーティションを使用して、データをデフォルトのトピックに送信します。KafkaOperations.sendDefault(IntegerSE partition, K key, @Nullable V data) 提供されたキーとパーティションを使用して、データをデフォルトのトピックに送信します。KafkaOperations.sendDefault(K key, @Nullable V data) 提供されたキーを使用してパーティションなしでデータをデフォルトのトピックに送信します。KafkaTemplate.sendDefault(@Nullable V data) KafkaTemplate.sendDefault(IntegerSE partition, LongSE timestamp, K key, @Nullable V data) KafkaTemplate.sendDefault(IntegerSE partition, K key, @Nullable V data) KafkaTemplate.sendDefault(K key, @Nullable V data) org.springframework.kafka.listener 内の SendResult 使用
型 SendResult の型引数を持つ org.springframework.kafka.listener のメソッドパラメーター修飾子と型メソッド説明protected voidDeadLetterPublishingRecoverer.verifySendResult(KafkaOperations<ObjectSE, ObjectSE> kafkaTemplate, org.apache.kafka.clients.producer.ProducerRecord<ObjectSE, ObjectSE> outRecord, @Nullable CompletableFutureSE<SendResult<ObjectSE, ObjectSE>> sendResult, org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> inRecord) sendの将来が完了するまで待ちます。org.springframework.kafka.requestreply 内の SendResult 使用
型 SendResult の引数を持つ型を返す org.springframework.kafka.requestreply のメソッド修飾子と型メソッド説明@Nullable CompletableFutureSE<SendResult<K, V>> RequestReplyFuture.getSendFuture()送信先を返します。@Nullable CompletableFutureSE<SendResult<K, V>> RequestReplyMessageFuture.getSendFuture()送信先を返します。型 SendResult の型引数を持つ org.springframework.kafka.requestreply のメソッドパラメーター修飾子と型メソッド説明protected voidRequestReplyFuture.setSendFuture(CompletableFutureSE<SendResult<K, V>> sendFuture)