クラス Kafka

メソッドの詳細

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

  戻り値:

  スペック。

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

  戻り値:

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

  戻り値:

  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