Class KafkaProperties

java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties

@ConfigurationProperties(prefix="spring.kafka") public class KafkaProperties extends Object
Configuration properties for Spring for Apache Kafka.

Users should refer to Kafka documentation for complete descriptions of these properties.

Since:
1.5.0
Author:
Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra
  • Constructor Details

    • KafkaProperties

      public KafkaProperties()
  • Method Details

    • getBootstrapServers

      public List<String> getBootstrapServers()
    • setBootstrapServers

      public void setBootstrapServers(List<String> bootstrapServers)
    • getClientId

      public String getClientId()
    • setClientId

      public void setClientId(String clientId)
    • getProperties

      public Map<String,String> 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()
    • buildConsumerProperties

      public Map<String,Object> buildConsumerProperties()
      Create an initial map of consumer properties from the state of this instance.

      This allows you to add additional properties, if necessary, and override the default kafkaConsumerFactory bean.

      Returns:
      the consumer properties initialized with the customizations defined on this instance
    • buildProducerProperties

      public Map<String,Object> buildProducerProperties()
      Create an initial map of producer properties from the state of this instance.

      This allows you to add additional properties, if necessary, and override the default kafkaProducerFactory bean.

      Returns:
      the producer properties initialized with the customizations defined on this instance
    • buildAdminProperties

      public Map<String,Object> buildAdminProperties()
      Create an initial map of admin properties from the state of this instance.

      This allows you to add additional properties, if necessary, and override the default kafkaAdmin bean.

      Returns:
      the admin properties initialized with the customizations defined on this instance
    • buildStreamsProperties

      public Map<String,Object> buildStreamsProperties()
      Create an initial map of streams properties from the state of this instance.

      This allows you to add additional properties, if necessary.

      Returns:
      the streams properties initialized with the customizations defined on this instance