パッケージ 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, Andy Wilkinson, Scott Frederick

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

    • 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 をオーバーライドしたりできます。

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

    • buildConsumerProperties

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

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

      パラメーター:
      sslBundles - SSL 信頼マテリアルを提供するバンドル
      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたコンシューマープロパティ

    • buildProducerProperties

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

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

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

    • buildProducerProperties

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

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

      パラメーター:
      sslBundles - SSL 信頼マテリアルを提供するバンドル
      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたプロデューサープロパティ

    • buildAdminProperties

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

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

      パラメーター:
      sslBundles - SSL 信頼マテリアルを提供するバンドル
      戻り値:
      このインスタンスで定義されたカスタマイズで初期化された管理プロパティ

    • buildStreamsProperties

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

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

      パラメーター:
      sslBundles - SSL 信頼マテリアルを提供するバンドル
      戻り値:
      このインスタンスで定義されたカスタマイズで初期化されたストリームプロパティ