メソッドの詳細

• outboundChannelAdapter

  public static <K,V> KafkaProducerMessageHandlerSpec<K,V,?> outboundChannelAdapter(org.springframework.kafka.core.KafkaTemplate<K,V> kafkaTemplate)

  初期 KafkaProducerMessageHandlerSpec を作成します。

  型パラメーター:

  K - Kafka メッセージキー型。

  V - Kafka メッセージ値型。

  パラメーター:

  kafkaTemplate - 使用する KafkaTemplate 

  戻り値:

  KafkaProducerMessageHandlerSpec。

• outboundChannelAdapter

  public static <K,V> KafkaProducerMessageHandlerSpec.KafkaProducerMessageHandlerTemplateSpec<K,V> outboundChannelAdapter(org.springframework.kafka.core.ProducerFactory<K,V> producerFactory)

  ProducerFactory を使用して初期 KafkaProducerMessageHandlerSpec を作成します。

  型パラメーター:

  K - Kafka メッセージキー型。

  V - Kafka メッセージ値型。

  パラメーター:

  producerFactory - ProducerFactory Java 8 ラムダ。

  戻り値:

  KafkaProducerMessageHandlerSpec。

  関連事項:

  Kafka プロデューサー構成

• inboundChannelAdapter

  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。

  戻り値:

  スペック。

  導入:

  3.2

• inboundChannelAdapter

  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。

  戻り値:

  スペック。

  導入:

  3.2

• inboundChannelAdapter

  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 - コールバックファクトリ。

  戻り値:

  スペック。

  導入:

  3.2

• inboundChannelAdapter

  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。

  戻り値:

  スペック。

  導入:

  3.2

• messageDrivenChannelAdapter

  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 - AbstractMessageListenerContainer

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec。

• messageDrivenChannelAdapter

  public 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 - AbstractMessageListenerContainer

  listenerMode - KafkaMessageDrivenChannelAdapter.ListenerMode

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec。

• messageDrivenChannelAdapter

  public 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 - ConsumerFactory

  containerProperties - 使用する ContainerProperties。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  containerProperties - 使用する ContainerProperties。

  listenerMode - KafkaMessageDrivenChannelAdapter.ListenerMode

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  public 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 - ConsumerFactory

  topicPartitions - TopicPartitionOffset vararg。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  listenerMode - KafkaMessageDrivenChannelAdapter.ListenerMode

  topicPartitions - TopicPartitionOffset vararg。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  topics - トピック vararg。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  listenerMode - KafkaMessageDrivenChannelAdapter.ListenerMode

  topics - トピック vararg。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  topicPattern - topicPattern 可変引数。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• messageDrivenChannelAdapter

  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 - ConsumerFactory

  listenerMode - KafkaMessageDrivenChannelAdapter.ListenerMode

  topicPattern - topicPattern 可変引数。

  戻り値:

  KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec。

• outboundGateway

  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 

  戻り値:

  KafkaGatewayMessageHandlerSpec。

  導入:

  3.0.2

• outboundGateway

  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)

  ProducerFactory を使用して初期 KafkaProducerMessageHandlerSpec を作成します。

  型パラメーター:

  K - Kafka メッセージキー型。

  V - Kafka メッセージ値型（リクエスト）。

  R - Kafka メッセージ値型（応答）。

  パラメーター:

  producerFactory - ProducerFactory Java 8 ラムダ。

  replyContainer - 返信用のリスナーコンテナー。

  戻り値:

  KafkaGatewayMessageHandlerSpec。

  導入:

  3.0.2

• inboundGateway

  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 - テンプレート。

  戻り値:

  スペック。

  導入:

  3.0.2

• inboundGateway

  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 - プロデューサーファクトリ。

  戻り値:

  スペック。

  導入:

  3.0.2

• inboundGateway

  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 - テンプレート仕様。

  戻り値:

  スペック。

  導入:

  3.0.2

• channel

  public static KafkaPointToPointChannelSpec channel(org.springframework.kafka.core.KafkaTemplate<?,?> template,
                                                     org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory,
                                                     StringSE topic)

  提供されたパラメーターを使用して、サブスクライブ可能なチャネルの仕様を作成します。

  パラメーター:

  template - テンプレート。

  containerFactory - コンテナーファクトリ。

  topic - トピック。

  戻り値:

  スペック。

  導入:

  3.3

• publishSubscribeChannel

  public static KafkaPublishSubscribeChannelSpec publishSubscribeChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template,
                                                                         org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory,
                                                                         StringSE topic)

  提供されたパラメーターを使用して、パブリッシュ / サブスクライブチャネルの仕様を作成します。

  パラメーター:

  template - テンプレート。

  containerFactory - コンテナーファクトリ。

  topic - トピック。

  戻り値:

  スペック。

  導入:

  3.3

• pollableChannel

  public static KafkaPollableChannelSpec pollableChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template,
                                                         KafkaMessageSource<?,?> source)

  提供されたパラメーターを使用して、ポーリング可能なチャネルの仕様を作成します。

  パラメーター:

  template - テンプレート。

  source - ソース。

  戻り値:

  スペック。

  導入:

  3.3