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

クラス KafkaStreamsInteractiveQueryService

java.lang.ObjectSE
org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService
public class KafkaStreamsInteractiveQueryService extends ObjectSE
Kafka ストリーム内のインタラクティブクエリストアを囲むラッパー API を提供します。この API を使用すると、アプリケーションは検討中の KafkaStreams 内の名前付き状態ストアにアクセスできます。
導入:
3.2
作成者:
Soby Chacko

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

  • メソッドの詳細

    • setRetryTemplate

      public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
      エンドユーザーが提供するカスタム RetryTemplate。
      パラメーター:
      retryTemplate - RetryTemplate

    • retrieveQueryableStore

      public <T> T retrieveQueryableStore(StringSE storeName, org.apache.kafka.streams.state.QueryableStoreType<T> storeType)
      アプリケーションで作成された名前でクエリ可能なストアを取得して返します。
      型パラメーター:
      T - クエリ可能なストアの汎用型
      パラメーター:
      storeName - クエリ可能なストアの名前
      storeType - クエリ可能なストアの型
      戻り値:
      クエリ可能なストア。

    • getCurrentKafkaStreamsApplicationHostInfo

      @Nullable public org.apache.kafka.streams.state.HostInfo getCurrentKafkaStreamsApplicationHostInfo()
      この Kafka Streams アプリケーションが実行されている現在の HostInfo を取得します。この {link @HostInfo} は Kafka `bootstrap.server` プロパティとは異なり、各 Kafka Streams アプリケーションインスタンスごとにユーザー定義の REST エンドポイントを呼び出すことができる Kafka Streams 構成プロパティ `application.server` に基づいています。このプロパティ (`application.server`) がエンドユーザーアプリケーションから使用できない場合は、null が返されます。
      戻り値:
      現在の HostInfo

    • getKafkaStreamsApplicationHostInfo

      public <K> org.apache.kafka.streams.state.HostInfo getKafkaStreamsApplicationHostInfo(StringSE store, K key, org.apache.kafka.common.serialization.Serializer<K> serializer)
      指定されたストアとキーがホストされている HostInfo を取得します。これは、アプリケーションを実行している現在のホストではない可能性があります。Kafka Streams は、同じアプリケーション ID のすべてのコンシューマーインスタンスを調べて、適切なホストを取得します。エンドユーザーアプリケーションは、このメソッドを呼び出すときに、すべてのアプリケーションインスタンスの構成プロパティとして `application.server` を提供する必要があることに注意してください。これが利用できない場合は、null が返される可能性があります。
      型パラメーター:
      K - キーの汎用型
      パラメーター:
      store - 店名
      key - 探すための鍵
      serializer - キーの Serializer 
      戻り値:
      提供されたストアのキーが現在ホストされている HostInfo