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 Description Consumer()
Method Summary
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 org.springframework.util.unit.DataSize getFetchMinSize()
setFetchMinSize
public void setFetchMinSize(org.springframework.util.unit.DataSize fetchMinSize)
getGroupId
public String getGroupId()
setGroupId
public void setGroupId(String groupId)
getHeartbeatInterval
public Duration getHeartbeatInterval()
setHeartbeatInterval
public void setHeartbeatInterval(Duration 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)
getProperties
public Map<String,String> getProperties()
buildProperties
public Map<String,Object> buildProperties()