クラス Kafka

java.lang.ObjectSE
org.springframework.integration.kafka.dsl.Kafka
public final class Kafka extends ObjectSE
Apache Kafka コンポーネントのファクトリクラス。
導入:
5.4
作成者:
Artem Bilan, Nasko Vasilev, Gary Russell, Anshul Mehra

  • メソッドの詳細

    • 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。
      関連事項:

    • 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。
      戻り値:
      スペック。

    • 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。
      戻り値:
      スペック。

    • 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 - コールバックファクトリ。
      戻り値:
      スペック。

    • 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。
      戻り値:
      スペック。

    • 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。

    • 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。

    • 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 - テンプレート。
      戻り値:
      スペック。

    • 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 - プロデューサーファクトリ。
      戻り値:
      スペック。

    • 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 - テンプレート仕様。
      戻り値:
      スペック。

    • channel

      public static KafkaPointToPointChannelSpec channel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic)
      提供されたパラメーターを使用して、サブスクライブ可能なチャネルの仕様を作成します。
      パラメーター:
      template - テンプレート。
      containerFactory - コンテナーファクトリ。
      topic - トピック。
      戻り値:
      スペック。

    • publishSubscribeChannel

      public static KafkaPublishSubscribeChannelSpec publishSubscribeChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> containerFactory, StringSE topic)
      提供されたパラメーターを使用して、パブリッシュ / サブスクライブチャネルの仕様を作成します。
      パラメーター:
      template - テンプレート。
      containerFactory - コンテナーファクトリ。
      topic - トピック。
      戻り値:
      スペック。

    • pollableChannel

      public static KafkaPollableChannelSpec pollableChannel(org.springframework.kafka.core.KafkaTemplate<?,?> template, KafkaMessageSource<?,?> source)
      提供されたパラメーターを使用して、ポーリング可能なチャネルの仕様を作成します。
      パラメーター:
      template - テンプレート。
      source - ソース。
      戻り値:
      スペック。
      導入:
      3.3