org.springframework.boot.autoconfigure.kafka

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 and Description
Producer()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	buildProperties()
String	getAcks()
DataSize	getBatchSize()
List<String>	getBootstrapServers()
DataSize	getBufferMemory()
String	getClientId()
String	getCompressionType()
Class<?>	getKeySerializer()
Map<String,String>	getProperties()
Integer	getRetries()
KafkaProperties.Security	getSecurity()
KafkaProperties.Ssl	getSsl()
String	getTransactionIdPrefix()
Class<?>	getValueSerializer()
void	setAcks(String acks)
void	setBatchSize(DataSize batchSize)
void	setBootstrapServers(List<String> bootstrapServers)
void	setBufferMemory(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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Producer

public Producer()

Method Detail

getSsl

public KafkaProperties.Ssl getSsl()

getSecurity

public KafkaProperties.Security getSecurity()

getAcks

public String getAcks()

setAcks

public void setAcks(String acks)

getBatchSize

public DataSize getBatchSize()

setBatchSize

public void setBatchSize(DataSize batchSize)

getBootstrapServers

public List<String> getBootstrapServers()

setBootstrapServers

public void setBootstrapServers(List<String> bootstrapServers)

getBufferMemory

public DataSize getBufferMemory()

setBufferMemory

public void setBufferMemory(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()