パッケージ org.springframework.boot.autoconfigure.kafka

クラス KafkaProperties

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

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

導入:
1.5.0
作成者:
Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes

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

    • KafkaProperties

      public KafkaProperties()

  • メソッドの詳細

    • getBootstrapServers

      public ListSE<StringSE> getBootstrapServers()

    • setBootstrapServers

      public void setBootstrapServers(ListSE<StringSE> bootstrapServers)

    • getClientId

      public StringSE getClientId()

    • setClientId

      public void setClientId(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()
      このインスタンスの状態からストリームプロパティの初期マップを作成します。

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

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