クラス AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>, C extends AbstractKafkaChannel>

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.dsl.MessageChannelSpec<S,C>
org.springframework.integration.kafka.dsl.AbstractKafkaChannelSpec<S,C>
型パラメーター:
S - スペック型。
C - チャネル型。
実装されているすべてのインターフェース:
DisposableBean、FactoryBean<C>、InitializingBean、Lifecycle、Phased、SmartLifecycle、ComponentsRegistration
既知の直属サブクラス
KafkaPollableChannelSpec, KafkaSubscribableChannelSpec
public abstract class AbstractKafkaChannelSpec<S extends AbstractKafkaChannelSpec<S,C>, C extends AbstractKafkaChannel> extends MessageChannelSpec<S,C>
Apache Kafka トピックによってサポートされるメッセージチャネルの仕様。
導入:
5.4
作成者:
Gary Russell

  • フィールドの詳細

    • groupId

      protected @Nullable StringSE groupId

  • コンストラクターの詳細

    • AbstractKafkaChannelSpec

      public AbstractKafkaChannelSpec()

  • メソッドの詳細

    • id

      public S id(StringSE idToSet)
      クラスからコピーされた説明: IntegrationComponentSpec
      コンポーネント識別子を構成します。このコンポーネントのアプリケーションコンテキストに Bean を登録するための beanName として使用されます。
      オーバーライド:
      クラス IntegrationComponentSpec<S extends AbstractKafkaChannelSpec<S,C>, C extends AbstractKafkaChannel> の id 
      パラメーター:
      idToSet - ID。
      戻り値:
      スペック。

    • groupId

      public S groupId(StringSE group)
      コンシューマー側で使用するグループ ID を設定します。
      パラメーター:
      group - グループ ID。
      戻り値:
      スペック。