インターフェースの使用
org.springframework.kafka.core.ProducerFactory
ProducerFactory を使用するパッケージ
パッケージ
説明
kafka コアコンポーネントのパッケージ
MockConsumer および MockProducer の使用をサポートするクラスを提供します。
リクエスト / 応答セマンティクスのクラスを提供します。
トランザクションに関連するクラスを提供します。
org.springframework.kafka.core 内の ProducerFactory 使用
ProducerFactory を実装している org.springframework.kafka.core のクラス修飾子と型クラス説明class修飾子と型メソッド説明DefaultKafkaProducerFactory.copyWithConfigurationOverride(MapSE<StringSE, ObjectSE> overrideProperties) インスタンスのプロパティと指定されたプロパティをコピーして、新しいプロデューサーファクトリを作成します。default ProducerFactory<K,V> ProducerFactory.copyWithConfigurationOverride(MapSE<StringSE, ObjectSE> overrideProperties) インスタンスのプロパティと指定されたプロパティをコピーして、新しいプロデューサーファクトリを作成します。default ProducerFactory<K,V> KafkaOperations.getProducerFactory()このテンプレートで使用されるプロデューサーファクトリを返します。KafkaTemplate.getProducerFactory()このテンプレートで使用されるプロデューサーファクトリを返します。protected ProducerFactory<K,V> KafkaTemplate.getProducerFactory(StringSE topic) トピックに基づいて、このテンプレートで使用されるプロデューサーファクトリを返します。RoutingKafkaTemplate.getProducerFactory()RoutingKafkaTemplate.getProducerFactory(StringSE topic) 型 ProducerFactory のパラメーターを持つ org.springframework.kafka.core のメソッド修飾子と型メソッド説明static <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory) 現在のトランザクションと同期している Producer を取得します (存在する場合)。static <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory, StringSE txIdPrefix, DurationSE closeTimeout) 現在のトランザクションと同期している Producer を取得します (存在する場合)。static <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory, DurationSE closeTimeout) 現在のトランザクションと同期している Producer を取得します (存在する場合)。型 ProducerFactory のパラメーターを持つ org.springframework.kafka.core のコンストラクター修飾子コンストラクター説明KafkaTemplate(ProducerFactory<K, V> producerFactory) 提供されたプロデューサーファクトリと autoFlush false を使用してインスタンスを作成します。KafkaTemplate(ProducerFactory<K, V> producerFactory, boolean autoFlush) 提供されたプロデューサーファクトリと autoFlush 設定を使用してインスタンスを作成します。KafkaTemplate(ProducerFactory<K, V> producerFactory, boolean autoFlush, MapSE<StringSE, ObjectSE> configOverrides) 提供されたプロデューサーファクトリと autoFlush 設定を使用してインスタンスを作成します。KafkaTemplate(ProducerFactory<K, V> producerFactory, MapSE<StringSE, ObjectSE> configOverrides) autoFlush を false にして、提供されたプロデューサーファクトリとプロパティを使用してインスタンスを作成します。型の型引数を持つ org.springframework.kafka.core のコンストラクターパラメーター ProducerFactory修飾子コンストラクター説明RoutingKafkaTemplate(MapSE<PatternSE, ProducerFactory<ObjectSE, ObjectSE>> factories) 提供されたプロパティを使用してインスタンスを構築します。org.springframework.kafka.mock 内の ProducerFactory 使用
ProducerFactory を実装している org.springframework.kafka.mock のクラスorg.springframework.kafka.requestreply 内の ProducerFactory 使用
型 ProducerFactory のパラメーターを持つ org.springframework.kafka.requestreply のコンストラクター修飾子コンストラクター説明AggregatingReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, CollectionSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> replyContainer, BiPredicateSE<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>, BooleanSE> releaseStrategy) 提供されたパラメーター引数を使用してインスタンスを構築します。ReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer) ReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer, boolean autoFlush) org.springframework.kafka.transaction 内の ProducerFactory 使用
修飾子と型メソッド説明ChainedKafkaTransactionManager.getProducerFactory()使用すべきではありません。KafkaAwareTransactionManager.getProducerFactory()生産ファクトリを取得します。KafkaTransactionManager.getProducerFactory()生産ファクトリを取得します。型 ProducerFactory のパラメーターを持つ org.springframework.kafka.transaction のコンストラクター修飾子コンストラクター説明KafkaTransactionManager(ProducerFactory<K, V> producerFactory) ProducerFactory を指定して、新しい KafkaTransactionManager を作成します。