インターフェースの使用
org.springframework.kafka.core.ConsumerFactory
ConsumerFactory を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
kafka コアコンポーネントのパッケージ
kafka リスナーのためのパッケージ
MockConsumer および MockProducer の使用をサポートするクラスを提供します。
org.springframework.kafka.config 内の ConsumerFactory 使用
修飾子と型メソッド説明@Nullable ConsumerFactory<? super K, ? super V> AbstractKafkaListenerContainerFactory.getConsumerFactory()型 ConsumerFactory のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明voidAbstractKafkaListenerContainerFactory.setConsumerFactory(ConsumerFactory<? super K, ? super V> consumerFactory) 使用するConsumerFactoryを指定します。org.springframework.kafka.core 内の ConsumerFactory 使用
ConsumerFactory を実装している org.springframework.kafka.core のクラス修飾子と型クラス説明classcreateConsumer()呼び出しごとに、提供されたMapSEconfigsおよびオプションのDeserializerの新しいConsumerインスタンスを生成するConsumerFactory実装。型 ConsumerFactory のパラメーターを持つ org.springframework.kafka.core のメソッド修飾子と型メソッド説明voidKafkaTemplate.setConsumerFactory(ConsumerFactory<K, V> consumerFactory) 受信操作用のコンシューマーファクトリを設定します。org.springframework.kafka.listener 内の ConsumerFactory 使用
ConsumerFactory として宣言されている org.springframework.kafka.listener のフィールド修飾子と型フィールド説明protected final @NonNull ConsumerFactory<K, V> AbstractMessageListenerContainer.consumerFactory型 ConsumerFactory のパラメーターを持つ org.springframework.kafka.listener のメソッド修飾子と型メソッド説明static <K,V> boolean ErrorHandlingUtils.checkDeserializer(ConsumerFactory<K, V> consumerFactory, PropertiesSE consumerOverrides, boolean isValue, @Nullable ClassLoaderSE classLoader) キーまたは値のデシリアライザーがErrorHandlingDeserializerのインスタンスであるかどうかを判断します。型 ConsumerFactory のパラメーターを持つ org.springframework.kafka.listener のコンストラクター修飾子コンストラクター説明protectedAbstractMessageListenerContainer(@Nullable ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) 提供されたファクトリとプロパティを使用してインスタンスを構築します。ConcurrentMessageListenerContainer(@Nullable ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) 提供された構成プロパティを使用してインスタンスを構築します。KafkaMessageListenerContainer(ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) 提供された構成プロパティを使用してインスタンスを構築します。org.springframework.kafka.mock 内の ConsumerFactory 使用
ConsumerFactory を実装している org.springframework.kafka.mock のクラス