パッケージ org.springframework.kafka.core

クラス KafkaResourceFactory

java.lang.ObjectSE
org.springframework.kafka.core.KafkaResourceFactory
既知の直属サブクラス
DefaultKafkaConsumerFactory、DefaultKafkaProducerFactory、KafkaAdmin
public abstract class KafkaResourceFactory extends ObjectSE
コンシューマー / プロデューサー / 管理者クリエーターの基本クラス。
導入:
2.5
作成者:
Gary Russell

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

    • KafkaResourceFactory

      public KafkaResourceFactory()

  • メソッドの詳細

    • getBootstrapServers

      @Nullable protected StringSE getBootstrapServers()

    • setBootstrapServersSupplier

      public void setBootstrapServersSupplier(SupplierSE<StringSE> bootstrapServersSupplier)
      サブクラスで構成されているものを上書きするように、ブートストラップサーバーリストのサプライヤーを設定します。
      パラメーター:
      bootstrapServersSupplier - サプライヤー。

    • checkBootstrap

      protected void checkBootstrap(MapSE<StringSE,ObjectSE> configs)
      setBootstrapServersSupplier(Supplier) を呼び出してプロパティを拡張し、ブートストラップサーバーのプロパティを置き換えます。
      パラメーター:
      configs - 構成。