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)

• 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()

• getSsl

  public KafkaProperties.Ssl getSsl()

• getJaas

  public KafkaProperties.Jaas getJaas()

• getTemplate

  public KafkaProperties.Template getTemplate()

• 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