パッケージ org.springframework.kafka.requestreply

インターフェース ReplyingKafkaOperations<K,V,R>

型パラメーター:
K - 鍵の型。
V - 送信データ型。
R - 応答データ型。
すべての既知の実装クラス:
AggregatingReplyingKafkaTemplate, ReplyingKafkaTemplate
public interface ReplyingKafkaOperations<K,V,R>
リクエスト / 応答操作。
導入:
2.1.3
作成者:
Gary Russell

  • メソッドの詳細

    • waitForAssignment

      default boolean waitForAssignment(DurationSE duration) throws InterruptedExceptionSE
      パーティションが割り当てられるまで待ちます。例: auto.offset.reset=latest の場合。手動割り当てを使用する場合、期間はコンテナーの pollTimeout プロパティよりも長くする必要があります。
      パラメーター:
      duration - どのぐらい待つのか。
      戻り値:
      パーティションが割り当てられている場合は true。
      例外:
      InterruptedExceptionSE - 待機中にスレッドが中断された場合。
      導入:
      2.8.8

    • sendAndReceive

      default RequestReplyMessageFuture<K,V> sendAndReceive(Message<?> message)
      リクエストメッセージを送信し、デフォルトのタイムアウトで応答メッセージを受信します。
      パラメーター:
      message - 送信するメッセージ。
      戻り値:
      RequestReplyMessageFuture。
      導入:
      2.7

    • sendAndReceive

      default RequestReplyMessageFuture<K,V> sendAndReceive(Message<?> message, @Nullable DurationSE replyTimeout)
      リクエストメッセージを送信し、応答メッセージを受信します。
      パラメーター:
      message - 送信するメッセージ。
      replyTimeout - 応答タイムアウト。null の場合、デフォルトが使用されます。
      戻り値:
      RequestReplyMessageFuture。
      導入:
      2.7

    • sendAndReceive

      default <P> RequestReplyTypedMessageFuture<K,V,P> sendAndReceive(Message<?> message, ParameterizedTypeReference<P> returnType)
      リクエストメッセージを送信し、応答メッセージを受信します。
      型パラメーター:
      P - 応答ペイロード型。
      パラメーター:
      message - 送信するメッセージ。
      returnType - 応答ペイロード型のメッセージコンバーターへのヒント。
      戻り値:
      RequestReplyMessageFuture。
      導入:
      2.7

    • sendAndReceive

      default <P> RequestReplyTypedMessageFuture<K,V,P> sendAndReceive(Message<?> message, DurationSE replyTimeout, ParameterizedTypeReference<P> returnType)
      リクエストメッセージを送信し、応答メッセージを受信します。
      型パラメーター:
      P - 応答ペイロード型。
      パラメーター:
      message - 送信するメッセージ。
      replyTimeout - 応答タイムアウト。null の場合、デフォルトが使用されます。
      returnType - 応答ペイロード型のメッセージコンバーターへのヒント。
      戻り値:
      RequestReplyMessageFuture。
      導入:
      2.7

    • sendAndReceive

      RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
      リクエストを送信し、デフォルトのタイムアウトで応答を受信します。
      パラメーター:
      record - 送信するレコード。
      戻り値:
      RequestReplyFuture。

    • sendAndReceive

      RequestReplyFuture<K,V,R> sendAndReceive(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, DurationSE replyTimeout)
      リクエストを送信し、返信を受け取ります。
      パラメーター:
      record - 送信するレコード。
      replyTimeout - 応答タイムアウト。null の場合、デフォルトが使用されます。
      戻り値:
      RequestReplyFuture。
      導入:
      2.3