org.springframework.boot.autoconfigure.kafka

Class KafkaProperties.Consumer

java.lang.Object

org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer

Enclosing class:

KafkaProperties

public static class KafkaProperties.Consumer
extends Object

Constructor Summary

Constructors

Constructor and Description
Consumer()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	buildProperties()
Integer	getAutoCommitInterval()
String	getAutoOffsetReset()
List<String>	getBootstrapServers()
String	getClientId()
Boolean	getEnableAutoCommit()
Integer	getFetchMaxWait()
Integer	getFetchMinSize()
String	getGroupId()
Integer	getHeartbeatInterval()
Class<?>	getKeyDeserializer()
Integer	getMaxPollRecords()
KafkaProperties.Ssl	getSsl()
Class<?>	getValueDeserializer()
void	setAutoCommitInterval(Integer autoCommitInterval)
void	setAutoOffsetReset(String autoOffsetReset)
void	setBootstrapServers(List<String> bootstrapServers)
void	setClientId(String clientId)
void	setEnableAutoCommit(Boolean enableAutoCommit)
void	setFetchMaxWait(Integer fetchMaxWait)
void	setFetchMinSize(Integer fetchMinSize)
void	setGroupId(String groupId)
void	setHeartbeatInterval(Integer heartbeatInterval)
void	setKeyDeserializer(Class<?> keyDeserializer)
void	setMaxPollRecords(Integer maxPollRecords)
void	setValueDeserializer(Class<?> valueDeserializer)

Methods inherited from class java.lang.Object

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

Constructor Detail

Consumer

public Consumer()

Method Detail

getSsl

public KafkaProperties.Ssl getSsl()

getAutoCommitInterval

public Integer getAutoCommitInterval()

setAutoCommitInterval

public void setAutoCommitInterval(Integer autoCommitInterval)

getAutoOffsetReset

public String getAutoOffsetReset()

setAutoOffsetReset

public void setAutoOffsetReset(String autoOffsetReset)

getBootstrapServers

public List<String> getBootstrapServers()

setBootstrapServers

public void setBootstrapServers(List<String> bootstrapServers)

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

getEnableAutoCommit

public Boolean getEnableAutoCommit()

setEnableAutoCommit

public void setEnableAutoCommit(Boolean enableAutoCommit)

getFetchMaxWait

public Integer getFetchMaxWait()

setFetchMaxWait

public void setFetchMaxWait(Integer fetchMaxWait)

getFetchMinSize

public Integer getFetchMinSize()

setFetchMinSize

public void setFetchMinSize(Integer fetchMinSize)

getGroupId

public String getGroupId()

setGroupId

public void setGroupId(String groupId)

getHeartbeatInterval

public Integer getHeartbeatInterval()

setHeartbeatInterval

public void setHeartbeatInterval(Integer heartbeatInterval)

getKeyDeserializer

public Class<?> getKeyDeserializer()

setKeyDeserializer

public void setKeyDeserializer(Class<?> keyDeserializer)

getValueDeserializer

public Class<?> getValueDeserializer()

setValueDeserializer

public void setValueDeserializer(Class<?> valueDeserializer)

getMaxPollRecords

public Integer getMaxPollRecords()

setMaxPollRecords

public void setMaxPollRecords(Integer maxPollRecords)

buildProperties

public Map<String,Object> buildProperties()