クラス AggregatingReplyingKafkaTemplate<K,V,R>

java.lang.ObjectSE
org.springframework.kafka.core.KafkaTemplate<K,V>
org.springframework.kafka.requestreply.ReplyingKafkaTemplate <K、V、コレクションSE<org.apache.kafka.clients.consumer.ConsumerRecord<K、R>>>
org.springframework.kafka.requestreply.AggregatingReplyingKafkaTemplate<K,V,R>
型パラメーター:
K - 鍵の型。
V - 送信データ型。
R - 応答データ型。
実装されているすべてのインターフェース:
EventListenerSE、Aware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationListener<ContextStoppedEvent>、Lifecycle、Phased、SmartLifecycle、KafkaOperations<K,V>、BatchConsumerAwareMessageListener<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>、BatchMessageListener<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>、ConsumerSeekAware、GenericMessageListener<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>>>、ReplyingKafkaOperations<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>
public class AggregatingReplyingKafkaTemplate<K,V,R> extends ReplyingKafkaTemplate<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> implements BatchConsumerAwareMessageListener<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>
同じ相関 ID を持つ複数の応答を集約する応答テンプレート。
導入:
2.3
作成者:
Gary Russell, Sanghyeok An

  • フィールドの詳細

    • AGGREGATED_RESULTS_TOPIC

      public static final StringSE AGGREGATED_RESULTS_TOPIC
      集約された結果を持つ「外部」 ConsumerRecord の疑似トピック名は、リリース戦略による通常のリリース後の値になります。
      関連事項:

    • PARTIAL_RESULTS_AFTER_TIMEOUT_TOPIC

      public static final StringSE PARTIAL_RESULTS_AFTER_TIMEOUT_TOPIC
      集約された結果を持つ「外部」 ConsumerRecord の疑似トピック名は、タイムアウト後の値になります。
      関連事項:

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

    • AggregatingReplyingKafkaTemplate

      public AggregatingReplyingKafkaTemplate(ProducerFactory<K,V> producerFactory, GenericMessageListenerContainer<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> replyContainer, BiPredicateSE<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>, BooleanSE> releaseStrategy)
      指定されたパラメーター引数を使用してインスタンスを構築します。コレクションがいつ「完了」するかを判断するために、releaseStrategy が参照されます。
      パラメーター:
      producerFactory - プロデューサーファクトリ。
      replyContainer - 返信コンテナー。
      releaseStrategy - 現在のリストと、これが通常の配信かタイムアウト (setReturnPartialOnTimeout(boolean) が true の場合) かを示すブール値が渡される BiPredicateSE であるリリース戦略。述語はレコードのリストを変更する場合があります。
      導入:
      2.3.5

  • メソッドの詳細

    • setCommitTimeout

      public void setCommitTimeout(DurationSE commitTimeout)
      オフセットをコミットするときに使用するタイムアウトを設定します。
      パラメーター:
      commitTimeout - タイムアウト。

    • setReturnPartialOnTimeout

      public void setReturnPartialOnTimeout(boolean returnPartialOnTimeout)
      true に設定すると、リクエストがタイムアウトしたときに部分的な結果が返されます。
      パラメーター:
      returnPartialOnTimeout - 部分的な結果を返す場合は true。

    • onMessage

      public void onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>>> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      インターフェースからコピーされた説明: GenericMessageListener
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース BatchConsumerAwareMessageListener<K,V> の onMessage 
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。
      consumer - コンシューマー。

    • handleTimeout

      protected boolean handleTimeout(ObjectSE correlationId, RequestReplyFuture<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> future)
      クラスからコピーされた説明: ReplyingKafkaTemplate
      リクエストがタイムアウトしたことをサブクラスに通知して、状態をクリーンアップし、オプションでフューチャーを完了することができるようにするために使用されます。
      オーバーライド:
      クラス ReplyingKafkaTemplate<K, V, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>> の handleTimeout 
      パラメーター:
      correlationId - 相関 ID。
      future - 未来。
      戻り値:
      true は、将来が完了したことを示します。