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()
Integer	getBatchSize()
List<String>	getBootstrapServers()
Long	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(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	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()

getAcks

public String getAcks()

setAcks

public void setAcks(String acks)

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)

getTransactionIdPrefix

public String getTransactionIdPrefix()

setTransactionIdPrefix

public void setTransactionIdPrefix(String transactionIdPrefix)

getProperties

public Map<String,String> getProperties()

buildProperties

public Map<String,Object> buildProperties()