クラス KafkaStreamsInteractiveQueryService
java.lang.ObjectSE
org.springframework.kafka.streams.KafkaStreamsInteractiveQueryService
Kafka ストリーム内のインタラクティブクエリストアを囲むラッパー API を提供します。この API を使用すると、アプリケーションは検討中の
KafkaStreams
内の名前付き状態ストアにアクセスできます。- 導入:
- 3.2
- 作成者:
- Soby Chacko
コンストラクターのサマリー
コンストラクターコンストラクター説明KafkaStreamsInteractiveQueryService
(StreamsBuilderFactoryBean streamsBuilderFactoryBean) StreamsBuilderFactoryBean
内の KafkaStreams から状態ストアを照会するためのインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明org.apache.kafka.streams.state.HostInfo
この Kafka ストリームアプリケーションが実行されている現在のHostInfo
を取得します。<K> org.apache.kafka.streams.state.HostInfo
getKafkaStreamsApplicationHostInfo
(StringSE store, K key, org.apache.kafka.common.serialization.Serializer<K> serializer) 提供されたストアとキーがホストされているHostInfo
を取得します。<T> T
retrieveQueryableStore
(StringSE storeName, org.apache.kafka.streams.state.QueryableStoreType<T> storeType) アプリケーションで作成された名前でクエリ可能なストアを取得して返します。void
setRetryTemplate
(org.springframework.retry.support.RetryTemplate retryTemplate) エンドユーザーが提供するカスタムRetryTemplate
。
コンストラクターの詳細
KafkaStreamsInteractiveQueryService
StreamsBuilderFactoryBean
内の KafkaStreams から状態ストアを照会するためのインスタンスを構築します。- パラメーター:
streamsBuilderFactoryBean
-KafkaStreams
のStreamsBuilderFactoryBean
。
メソッドの詳細
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