クラス KafkaStreamsInteractiveQueryService

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

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

  • メソッドの詳細

    • setRetryTemplate

      public void setRetryTemplate(RetryTemplate retryTemplate)
      Custom RetryTemplate provided by the end users.
      パラメーター:
      retryTemplate - RetryTemplate

    • retrieveQueryableStore

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

    • getCurrentKafkaStreamsApplicationHostInfo

      public @Nullable org.apache.kafka.streams.state.HostInfo getCurrentKafkaStreamsApplicationHostInfo()
      Retrieve the current HostInfo where this Kafka Streams application is running on. This {link @HostInfo} is different from the Kafka `bootstrap.server` property and is based on the Kafka Streams configuration property `application.server` where user-defined REST endpoints can be invoked per each Kafka Streams application instance. If this property - `application.server` - is not available from the end-user application, then null is returned.
      戻り値:
      現在の HostInfo

    • getKafkaStreamsApplicationHostInfo

      public <K> org.apache.kafka.streams.state.HostInfo getKafkaStreamsApplicationHostInfo(StringSE store, K key, org.apache.kafka.common.serialization.Serializer<K> serializer)
      Retrieve the HostInfo where the provided store and key are hosted on. This may not be the current host that is running the application. Kafka Streams will look through all the consumer instances under the same application id and retrieve the proper host. Note that the end user applications must provide `application.server` as a configuration property for all the application instances when calling this method. If this is not available, then null maybe returned.
      型パラメーター:
      K - キーの汎用型
      パラメーター:
      store - 店名
      key - 探すための鍵
      serializer - キーの Serializer 
      戻り値:
      提供されたストアのキーが現在ホストされている HostInfo