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()
org.springframework.util.unit.DataSize
getBatchSize()
List<String>
getBootstrapServers()
org.springframework.util.unit.DataSize
getBufferMemory()
String
getClientId()
String
getCompressionType()
Class<?>
getKeySerializer()
Map<String,String>
getProperties()
Integer
getRetries()
KafkaProperties.Ssl
getSsl()
String
getTransactionIdPrefix()
Class<?>
getValueSerializer()
void
setAcks(String acks)
void
setBatchSize(org.springframework.util.unit.DataSize batchSize)
void
setBootstrapServers(List<String> bootstrapServers)
void
setBufferMemory(org.springframework.util.unit.DataSize bufferMemory)
void
setClientId(String clientId)
void
setCompressionType(String compressionType)
void
setKeySerializer(Class<?> keySerializer)
void
setRetries(Integer retries)
void
setTransactionIdPrefix(String transactionIdPrefix)
void
setValueSerializer(Class<?> valueSerializer)
Constructor Detail
Producer
public Producer()
Method Detail
getSsl
public KafkaProperties.Ssl getSsl()
getBatchSize
public org.springframework.util.unit.DataSize getBatchSize()
setBatchSize
public void setBatchSize(org.springframework.util.unit.DataSize batchSize)
getBootstrapServers
public List<String> getBootstrapServers()
setBootstrapServers
public void setBootstrapServers(List<String> bootstrapServers)
getBufferMemory
public org.springframework.util.unit.DataSize getBufferMemory()
setBufferMemory
public void setBufferMemory(org.springframework.util.unit.DataSize 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)
getTransactionIdPrefix
public String getTransactionIdPrefix()
setTransactionIdPrefix
public void setTransactionIdPrefix(String transactionIdPrefix)
getProperties
public Map<String,String> getProperties()
buildProperties
public Map<String,Object> buildProperties()