インターフェースの使用
org.springframework.kafka.config.KafkaListenerEndpoint
KafkaListenerEndpoint を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
再試行可能なトピック処理用のパッケージ。
org.springframework.kafka.config 内の KafkaListenerEndpoint 使用
KafkaListenerEndpoint を実装している org.springframework.kafka.config のクラス修飾子と型クラス説明classKafka リスナーエンドポイントの基本モデル。classこのエンドポイントの受信メッセージを処理するために呼び出すメソッドを提供するKafkaListenerEndpoint。classKafkaHandlerに基づくいくつかの POJO メソッドのMethodKafkaListenerEndpoint拡張。型 KafkaListenerEndpoint のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明protected CAbstractKafkaListenerContainerFactory.createContainer(KafkaListenerEndpoint endpoint) protected abstract CAbstractKafkaListenerContainerFactory.createContainerInstance(KafkaListenerEndpoint endpoint) 空のコンテナーインスタンスを作成します。protected ConcurrentMessageListenerContainer<K,V> ConcurrentKafkaListenerContainerFactory.createContainerInstance(KafkaListenerEndpoint endpoint) AbstractKafkaListenerContainerFactory.createListenerContainer(KafkaListenerEndpoint endpoint) KafkaListenerContainerFactory.createListenerContainer(KafkaListenerEndpoint endpoint) 指定されたKafkaListenerEndpointのMessageListenerContainerを作成します。protected MessageListenerContainerKafkaListenerEndpointRegistry.createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) 指定されたファクトリを使用して、新しいMessageListenerContainerを作成して開始します。protected voidAbstractKafkaListenerContainerFactory.customizeContainer(C instance, KafkaListenerEndpoint endpoint) protected voidAbstractKafkaListenerContainerFactory.initializeContainer(C instance, KafkaListenerEndpoint endpoint) さらに、指定されたコンテナーを初期化します。protected voidConcurrentKafkaListenerContainerFactory.initializeContainer(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) voidKafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint) デフォルトのKafkaListenerContainerFactoryを使用して新しいKafkaListenerEndpointを登録し、基になるコンテナーを作成します。voidKafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) 基になるコンテナーの作成に使用するKafkaListenerContainerFactoryと一緒に新しいKafkaListenerEndpointを登録します。voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) 指定されたKafkaListenerEndpointのメッセージリスナーコンテナーを作成します。voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately) 指定されたKafkaListenerEndpointのメッセージリスナーコンテナーを作成します。org.springframework.kafka.retrytopic 内の KafkaListenerEndpoint 使用
型 KafkaListenerEndpoint のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getClientIdPrefix(KafkaListenerEndpoint endpoint) エンドポイントの clientId プレフィックスをオーバーライドする clientId プレフィックスを返します。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getClientIdPrefix(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getEndpointId(KafkaListenerEndpoint endpoint) エンドポイントの現在の ID を上書きするエンドポイント ID を返します。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getEndpointId(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroup(KafkaListenerEndpoint endpoint) エンドポイントのグループをオーバーライドするグループを返します。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroup(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroupId(KafkaListenerEndpoint endpoint) エンドポイントの groupId をオーバーライドする groupId を返します。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroupId(KafkaListenerEndpoint endpoint)