@ConfigurationProperties(prefix="spring.kafka") public class KafkaProperties extends Object
Users should refer to Kafka documentation for complete descriptions of these properties.
static class
KafkaProperties.Admin
KafkaProperties.Consumer
KafkaProperties.Jaas
KafkaProperties.Listener
KafkaProperties.Producer
KafkaProperties.Ssl
KafkaProperties.Template
KafkaProperties()
Map<String,Object>
buildAdminProperties()
buildConsumerProperties()
buildProducerProperties()
getAdmin()
List<String>
getBootstrapServers()
String
getClientId()
getConsumer()
getJaas()
getListener()
getProducer()
Map<String,String>
getProperties()
getSsl()
getTemplate()
void
setBootstrapServers(List<String> bootstrapServers)
setClientId(String clientId)
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public KafkaProperties()
public List<String> getBootstrapServers()
public void setBootstrapServers(List<String> bootstrapServers)
public String getClientId()
public void setClientId(String clientId)
public Map<String,String> getProperties()
public KafkaProperties.Consumer getConsumer()
public KafkaProperties.Producer getProducer()
public KafkaProperties.Listener getListener()
public KafkaProperties.Admin getAdmin()
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Jaas getJaas()
public KafkaProperties.Template getTemplate()
public Map<String,Object> buildConsumerProperties()
This allows you to add additional properties, if necessary, and override the default kafkaConsumerFactory bean.
public Map<String,Object> buildProducerProperties()
This allows you to add additional properties, if necessary, and override the default kafkaProducerFactory bean.
public Map<String,Object> buildAdminProperties()
This allows you to add additional properties, if necessary, and override the default kafkaAdmin bean.
Impressum und Datenschutz Copyright ©2018 eir.me