public final class Kafka extends ObjectSE
| 修飾子と型 | メソッドと説明 |
|---|---|
static KafkaPointToPointChannelSpec | channel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic) 提供されたパラメーターを使用して、サブスクライブ可能なチャネルの仕様を作成します。 |
static <K,V> KafkaInboundChannelAdapterSpec<K,V> | inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties) コンシューマーファクトリとトピックを使用して初期 KafkaInboundChannelAdapterSpec を作成します。 |
static <K,V> KafkaInboundChannelAdapterSpec<K,V> | inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, boolean allowMultiFetch) コンシューマーファクトリとトピックを使用して初期 KafkaInboundChannelAdapterSpec を作成します。 |
static <K,V> KafkaInboundChannelAdapterSpec<K,V> | inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory) コンシューマーファクトリを使用して初期 KafkaInboundChannelAdapterSpec を作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。 |
static <K,V> KafkaInboundChannelAdapterSpec<K,V> | inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, boolean allowMultiFetch) コンシューマーファクトリを使用して初期 KafkaInboundChannelAdapterSpec を作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。 |
static <K,V,R> KafkaInboundGatewaySpec<K,V,R,?> | inboundGateway(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> container, org.springframework.kafka.core.KafkaTemplate<K,R> template) 提供されたコンテナーとテンプレートを使用して、初期 KafkaInboundGatewaySpec を作成します。 |
static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> | inboundGateway(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, org.springframework.kafka.core.ProducerFactory<K,R> producerFactory) 提供されたコンシューマーファクトリ、コンテナープロパティ、プロデューサーファクトリを使用して初期 KafkaInboundGatewaySpec を作成します。 |
static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> | inboundGateway(KafkaMessageListenerContainerSpec<K,V> containerSpec, KafkaTemplateSpec<K,R> templateSpec) 提供されたコンテナーとテンプレートの仕様を使用して、初期 KafkaInboundGatewaySpec を作成します。 |
static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> | messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer) 初期 KafkaMessageDrivenChannelAdapterSpec を作成します。 |
static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> | messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode) 初期 KafkaMessageDrivenChannelAdapterSpec を作成します。 |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, PatternSE topicPattern) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, StringSE... topics) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, PatternSE topicPattern) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, StringSE... topics) |
static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> | messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions) |
static <K,V> KafkaProducerMessageHandlerSpec<K,V,?> | outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate) 初期 KafkaProducerMessageHandlerSpec を作成します。 |
static <K,V> KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> | outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)ProducerFactory を使用して初期 KafkaProducerMessageHandlerSpec を作成します。 |
static <K,V,R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> | outboundGateway(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory, org.springframework.kafka.listener.GenericMessageListenerContainer<K,R> replyContainer)ProducerFactory を使用して初期 KafkaProducerMessageHandlerSpec を作成します。 |
static <K,V,R> KafkaOutboundGatewaySpec<K,V,R,?> | outboundGateway(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> kafkaTemplate) 初期 KafkaProducerMessageHandlerSpec を作成します。 |
static KafkaPollableChannelSpec | pollableChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, KafkaMessageSource<?,?> source) 提供されたパラメーターを使用して、ポーリング可能なチャネルの仕様を作成します。 |
static KafkaPublishSubscribeChannelSpec | publishSubscribeChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic) 提供されたパラメーターを使用して、パブリッシュ / サブスクライブチャネルの仕様を作成します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic static <K,V> KafkaProducerMessageHandlerSpec<K,V,?> outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)
KafkaProducerMessageHandlerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。kafkaTemplate - 使用する KafkaTemplate public static <K,V> KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)
KafkaProducerMessageHandlerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。producerFactory - ProducerFactory Java 8 ラムダ。public static <K,V> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties)
KafkaInboundChannelAdapterSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - コンシューマーファクトリ。consumerProperties - consumerProperties。public static <K,V> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, boolean allowMultiFetch)
KafkaInboundChannelAdapterSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - コンシューマーファクトリ。consumerProperties - consumerProperties。allowMultiFetch - 各ポーリングで複数のレコードをフェッチする場合は true。public static <K,V> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory)
KafkaInboundChannelAdapterSpec を作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - コンシューマーファクトリ。consumerProperties - consumerProperties。ackCallbackFactory - コールバックファクトリ。public static <K,V> KafkaInboundChannelAdapterSpec<K,V> inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, boolean allowMultiFetch)
KafkaInboundChannelAdapterSpec を作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - コンシューマーファクトリ。consumerProperties - consumerProperties。ackCallbackFactory - コールバックファクトリ。allowMultiFetch - 各ポーリングで複数のレコードをフェッチする場合は true。public static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer)
KafkaMessageDrivenChannelAdapterSpec を作成します。リスナーコンテナーがまだ Bean でない場合は、アプリケーションコンテキストに登録されます。アダプター仕様に id がある場合、Bean 名はその ID に ".container" が付加されたものになります。それ以外の場合、Bean 名はコンテナークラス名から生成されます。K - Kafka メッセージキー型。V - Kafka メッセージ値型。listenerContainer - AbstractMessageListenerContainerpublic static <K,V> KafkaMessageDrivenChannelAdapterSpec<K,V,?> messageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> listenerContainer, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode)
KafkaMessageDrivenChannelAdapterSpec を作成します。リスナーコンテナーがまだ Bean でない場合は、アプリケーションコンテキストに登録されます。アダプター仕様に id がある場合、Bean 名はその ID に ".container" が付加されたものになります。それ以外の場合、Bean 名はコンテナークラス名から生成されます。K - Kafka メッセージキー型。V - Kafka メッセージ値型。listenerContainer - AbstractMessageListenerContainerlistenerMode - KafkaMessageDrivenChannelAdapter.ListenerModepublic static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorycontainerProperties - 使用する ContainerProperties。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorycontainerProperties - 使用する ContainerProperties。listenerMode - KafkaMessageDrivenChannelAdapter.ListenerModepublic static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorytopicPartitions - TopicPartitionOffset vararg。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, org.springframework.kafka.support.TopicPartitionOffset... topicPartitions)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorylistenerMode - KafkaMessageDrivenChannelAdapter.ListenerModetopicPartitions - TopicPartitionOffset vararg。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, StringSE... topics)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorytopics - トピック vararg。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, StringSE... topics)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorylistenerMode - KafkaMessageDrivenChannelAdapter.ListenerModetopics - トピック vararg。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, PatternSE topicPattern)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorytopicPattern - topicPattern 可変引数。public static <K,V> KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V> messageDrivenChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, KafkaMessageDrivenChannelAdapter.ListenerMode listenerMode, PatternSE topicPattern)
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型。consumerFactory - ConsumerFactorylistenerMode - KafkaMessageDrivenChannelAdapter.ListenerModetopicPattern - topicPattern 可変引数。public static <K,V,R> KafkaOutboundGatewaySpec<K,V,R,?> outboundGateway(org.springframework.kafka.requestreply.ReplyingKafkaTemplate<K,V,R> kafkaTemplate)
KafkaProducerMessageHandlerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型(リクエスト)。R - Kafka メッセージ値型(応答)。kafkaTemplate - 使用する ReplyingKafkaTemplate public static <K,V,R> KafkaOutboundGatewaySpec.KafkaGatewayMessageHandlerTemplateSpec<K,V,R> outboundGateway(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory, org.springframework.kafka.listener.GenericMessageListenerContainer<K,R> replyContainer)
KafkaProducerMessageHandlerSpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型(リクエスト)。R - Kafka メッセージ値型(応答)。producerFactory - ProducerFactory Java 8 ラムダ。replyContainer - 返信用のリスナーコンテナー。public static <K,V,R> KafkaInboundGatewaySpec<K,V,R,?> inboundGateway(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> container, org.springframework.kafka.core.KafkaTemplate<K,R> template)
KafkaInboundGatewaySpec を作成します。リスナーコンテナーがまだ Bean でない場合は、アプリケーションコンテキストに登録されます。アダプター仕様に id がある場合、Bean 名はその ID に ".container" が付加されたものになります。それ以外の場合、Bean 名はコンテナークラス名から生成されます。K - Kafka メッセージキー型。V - Kafka メッセージ値型(リクエスト)。R - Kafka メッセージ値型(応答)。container - コンテナー。template - テンプレート。public static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> inboundGateway(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ContainerProperties containerProperties, org.springframework.kafka.core.ProducerFactory<K,R> producerFactory)
KafkaInboundGatewaySpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型(リクエスト)。R - Kafka メッセージ値型(応答)。consumerFactory - コンシューマーファクトリ。containerProperties - コンテナーのプロパティ。producerFactory - プロデューサーファクトリ。public static <K,V,R> KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K,V,R> inboundGateway(KafkaMessageListenerContainerSpec<K,V> containerSpec, KafkaTemplateSpec<K,R> templateSpec)
KafkaInboundGatewaySpec を作成します。K - Kafka メッセージキー型。V - Kafka メッセージ値型(リクエスト)。R - Kafka メッセージ値型(応答)。containerSpec - コンテナー仕様。templateSpec - テンプレート仕様。public static KafkaPointToPointChannelSpec channel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic)
template - テンプレート。containerFactory - コンテナーファクトリ。topic - トピック。public static KafkaPublishSubscribeChannelSpec publishSubscribeChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic)
template - テンプレート。containerFactory - コンテナーファクトリ。topic - トピック。public static KafkaPollableChannelSpec pollableChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, KafkaMessageSource<?,?> source)
template - テンプレート。source - ソース。