Class KafkaProperties.Producer

java.lang.Object

org.springframework.boot.kafka.autoconfigure.KafkaProperties.Producer

Enclosing class:

KafkaProperties

public static class KafkaProperties.Producer
extends Object

Since:

4.0.0

Author:

Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

Constructor Summary

Constructors

Constructor	Description
Producer()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	buildProperties()
@Nullable String	getAcks()
@Nullable DataSize	getBatchSize()
@Nullable List<String>	getBootstrapServers()
@Nullable DataSize	getBufferMemory()
@Nullable String	getClientId()
@Nullable String	getCompressionType()
Class<?>	getKeySerializer()
Map<String,String>	getProperties()
@Nullable Integer	getRetries()
KafkaProperties.Security	getSecurity()
KafkaProperties.Ssl	getSsl()
@Nullable String	getTransactionIdPrefix()
Class<?>	getValueSerializer()
void	setAcks(@Nullable String acks)
void	setBatchSize(@Nullable DataSize batchSize)
void	setBootstrapServers(@Nullable List<String> bootstrapServers)
void	setBufferMemory(@Nullable DataSize bufferMemory)
void	setClientId(@Nullable String clientId)
void	setCompressionType(@Nullable String compressionType)
void	setKeySerializer(Class<?> keySerializer)
void	setRetries(@Nullable Integer retries)
void	setTransactionIdPrefix(@Nullable String transactionIdPrefix)
void	setValueSerializer(Class<?> valueSerializer)

Methods inherited from class Object

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

Constructor Details

Producer

public Producer()

Method Details

getSsl

public KafkaProperties.Ssl getSsl()

getSecurity

public KafkaProperties.Security getSecurity()

getAcks

public @Nullable String getAcks()

setAcks

public void setAcks(@Nullable String acks)

getBatchSize

public @Nullable DataSize getBatchSize()

setBatchSize

public void setBatchSize(@Nullable DataSize batchSize)

getBootstrapServers

public @Nullable List<String> getBootstrapServers()

setBootstrapServers

public void setBootstrapServers(@Nullable List<String> bootstrapServers)

getBufferMemory

public @Nullable DataSize getBufferMemory()

setBufferMemory

public void setBufferMemory(@Nullable DataSize bufferMemory)

getClientId

public @Nullable String getClientId()

setClientId

public void setClientId(@Nullable String clientId)

getCompressionType

public @Nullable String getCompressionType()

setCompressionType

public void setCompressionType(@Nullable String compressionType)

getKeySerializer

public Class<?> getKeySerializer()

setKeySerializer

public void setKeySerializer(Class<?> keySerializer)

getValueSerializer

public Class<?> getValueSerializer()

setValueSerializer

public void setValueSerializer(Class<?> valueSerializer)

getRetries

public @Nullable Integer getRetries()

setRetries

public void setRetries(@Nullable Integer retries)

getTransactionIdPrefix

public @Nullable String getTransactionIdPrefix()

setTransactionIdPrefix

public void setTransactionIdPrefix(@Nullable String transactionIdPrefix)

getProperties

public Map<String,String> getProperties()

buildProperties

public Map<String,Object> buildProperties()