Class KafkaProperties.Producer
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Producer
- Enclosing class:
- KafkaProperties
public static class KafkaProperties.Producer extends Object
Constructor Summary
Constructors Constructor Description Producer()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<String,Object>
buildProperties()
String
getAcks()
Integer
getBatchSize()
List<String>
getBootstrapServers()
Long
getBufferMemory()
String
getClientId()
String
getCompressionType()
Class<?>
getKeySerializer()
Integer
getRetries()
KafkaProperties.Ssl
getSsl()
Class<?>
getValueSerializer()
void
setAcks(String acks)
void
setBatchSize(Integer batchSize)
void
setBootstrapServers(List<String> bootstrapServers)
void
setBufferMemory(Long bufferMemory)
void
setClientId(String clientId)
void
setCompressionType(String compressionType)
void
setKeySerializer(Class<?> keySerializer)
void
setRetries(Integer retries)
void
setValueSerializer(Class<?> valueSerializer)
Constructor Detail
Producer
public Producer()
Method Detail
getSsl
public KafkaProperties.Ssl getSsl()
getBatchSize
public Integer getBatchSize()
setBatchSize
public void setBatchSize(Integer batchSize)
getBootstrapServers
public List<String> getBootstrapServers()
setBootstrapServers
public void setBootstrapServers(List<String> bootstrapServers)
getBufferMemory
public Long getBufferMemory()
setBufferMemory
public void setBufferMemory(Long bufferMemory)
getClientId
public String getClientId()
setClientId
public void setClientId(String clientId)
getCompressionType
public String getCompressionType()
setCompressionType
public void setCompressionType(String compressionType)
getKeySerializer
public Class<?> getKeySerializer()
setKeySerializer
public void setKeySerializer(Class<?> keySerializer)
getValueSerializer
public Class<?> getValueSerializer()
setValueSerializer
public void setValueSerializer(Class<?> valueSerializer)
getRetries
public Integer getRetries()
setRetries
public void setRetries(Integer retries)
buildProperties
public Map<String,Object> buildProperties()