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()
Duration	getAutoCommitInterval()
String	getAutoOffsetReset()
List<String>	getBootstrapServers()
String	getClientId()
Boolean	getEnableAutoCommit()
Duration	getFetchMaxWait()
DataSize	getFetchMinSize()
String	getGroupId()
Duration	getHeartbeatInterval()
org.apache.kafka.common.requests.IsolationLevel	getIsolationLevel()
Class<?>	getKeyDeserializer()
Integer	getMaxPollRecords()
Map<String,String>	getProperties()
KafkaProperties.Ssl	getSsl()
Class<?>	getValueDeserializer()
void	setAutoCommitInterval(Duration autoCommitInterval)
void	setAutoOffsetReset(String autoOffsetReset)
void	setBootstrapServers(List<String> bootstrapServers)
void	setClientId(String clientId)
void	setEnableAutoCommit(Boolean enableAutoCommit)
void	setFetchMaxWait(Duration fetchMaxWait)
void	setFetchMinSize(DataSize fetchMinSize)
void	setGroupId(String groupId)
void	setHeartbeatInterval(Duration heartbeatInterval)
void	setIsolationLevel(org.apache.kafka.common.requests.IsolationLevel isolationLevel)
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 Duration getAutoCommitInterval()

setAutoCommitInterval

public void setAutoCommitInterval(Duration 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 Duration getFetchMaxWait()

setFetchMaxWait

public void setFetchMaxWait(Duration fetchMaxWait)

getFetchMinSize

public DataSize getFetchMinSize()

setFetchMinSize

public void setFetchMinSize(DataSize fetchMinSize)

getGroupId

public String getGroupId()

setGroupId

public void setGroupId(String groupId)

getHeartbeatInterval

public Duration getHeartbeatInterval()

setHeartbeatInterval

public void setHeartbeatInterval(Duration heartbeatInterval)

getIsolationLevel

public org.apache.kafka.common.requests.IsolationLevel getIsolationLevel()

setIsolationLevel

public void setIsolationLevel(org.apache.kafka.common.requests.IsolationLevel isolationLevel)

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)

getProperties

public Map<String,String> getProperties()

buildProperties

public Map<String,Object> buildProperties()