クラス 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 - 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