クラス KafkaProperties

java.lang.ObjectSE
org.springframework.boot.kafka.autoconfigure.KafkaProperties
@ConfigurationProperties("spring.kafka") public class KafkaProperties extends ObjectSE
Spring for Apache Kafka の構成プロパティ。

これらのプロパティの詳細については、Kafka のドキュメントを参照してください。

導入:
4.0.0
作成者:
Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

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

    • KafkaProperties

      public KafkaProperties()

  • メソッドの詳細

    • getBootstrapServers

      public ListSE<StringSE> getBootstrapServers()

    • setBootstrapServers

      public void setBootstrapServers(ListSE<StringSE> bootstrapServers)

    • getClientId

      public @Nullable StringSE getClientId()

    • setClientId

      public void setClientId(@Nullable StringSE clientId)

    • getProperties

      public MapSE<StringSE,StringSE> getProperties()

    • getConsumer

      public KafkaProperties.Consumer getConsumer()

    • getProducer

      public KafkaProperties.Producer getProducer()

    • getListener

      public KafkaProperties.Listener getListener()

    • getAdmin

      public KafkaProperties.Admin getAdmin()

    • getStreams

      public KafkaProperties.Streams getStreams()

    • getSsl

      public KafkaProperties.Ssl getSsl()

    • getJaas

      public KafkaProperties.Jaas getJaas()

    • getTemplate

      public KafkaProperties.Template getTemplate()

    • getSecurity

      public KafkaProperties.Security getSecurity()

    • getRetry

      public KafkaProperties.Retry getRetry()

    • buildConsumerProperties

      public MapSE<StringSE,ObjectSE> buildConsumerProperties()
      このインスタンスの状態からコンシューマープロパティの初期マップを作成します。

      これにより、必要に応じてプロパティを追加したり、デフォルトの kafkaConsumerFactory Bean をオーバーライドしたりできます。

      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたコンシューマープロパティ

    • buildProducerProperties

      public MapSE<StringSE,ObjectSE> buildProducerProperties()
      このインスタンスの状態からプロデューサープロパティの初期マップを作成します。

      これにより、必要に応じてプロパティを追加したり、デフォルトの kafkaProducerFactory Bean をオーバーライドしたりできます。

      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたプロデューサープロパティ

    • buildAdminProperties

      public MapSE<StringSE,ObjectSE> buildAdminProperties()
      このインスタンスの状態から管理プロパティの初期マップを作成します。

      これにより、必要に応じてプロパティを追加したり、デフォルトの kafkaAdmin Bean をオーバーライドしたりできます。

      戻り値:
      このインスタンスで定義されたカスタマイズで初期化された管理プロパティ

    • buildStreamsProperties

      public MapSE<StringSE,ObjectSE> buildStreamsProperties()
      このインスタンスの状態からストリームプロパティの初期マップを作成します。

      これにより、必要に応じてプロパティを追加できます。

      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたストリームプロパティ