org.springframework.boot.autoconfigure.kafka

Class 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 Detail

      • KafkaProperties

        public KafkaProperties()
    • Method Detail

      • getBootstrapServers

        public List<String> getBootstrapServers()
      • setBootstrapServers

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

        public String getClientId()
      • setClientId

        public void setClientId(String clientId)
      • 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