Class KafkaProperties.Listener
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Listener
- Enclosing class:
- KafkaProperties
public static class KafkaProperties.Listener extends Object
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
KafkaProperties.Listener.Type
Constructor Summary
Constructors Constructor Description Listener()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Integer
getAckCount()
org.springframework.kafka.listener.ContainerProperties.AckMode
getAckMode()
Duration
getAckTime()
String
getClientId()
Integer
getConcurrency()
Duration
getIdleEventInterval()
Boolean
getLogContainerConfig()
Duration
getMonitorInterval()
Float
getNoPollThreshold()
Duration
getPollTimeout()
KafkaProperties.Listener.Type
getType()
void
setAckCount(Integer ackCount)
void
setAckMode(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode)
void
setAckTime(Duration ackTime)
void
setClientId(String clientId)
void
setConcurrency(Integer concurrency)
void
setIdleEventInterval(Duration idleEventInterval)
void
setLogContainerConfig(Boolean logContainerConfig)
void
setMonitorInterval(Duration monitorInterval)
void
setNoPollThreshold(Float noPollThreshold)
void
setPollTimeout(Duration pollTimeout)
void
setType(KafkaProperties.Listener.Type type)
Constructor Detail
Listener
public Listener()
Method Detail
getType
public KafkaProperties.Listener.Type getType()
setType
public void setType(KafkaProperties.Listener.Type type)
getAckMode
public org.springframework.kafka.listener.ContainerProperties.AckMode getAckMode()
setAckMode
public void setAckMode(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode)
getClientId
public String getClientId()
setClientId
public void setClientId(String clientId)
getConcurrency
public Integer getConcurrency()
setConcurrency
public void setConcurrency(Integer concurrency)
getPollTimeout
public Duration getPollTimeout()
setPollTimeout
public void setPollTimeout(Duration pollTimeout)
getNoPollThreshold
public Float getNoPollThreshold()
setNoPollThreshold
public void setNoPollThreshold(Float noPollThreshold)
getAckCount
public Integer getAckCount()
setAckCount
public void setAckCount(Integer ackCount)
getAckTime
public Duration getAckTime()
setAckTime
public void setAckTime(Duration ackTime)
getIdleEventInterval
public Duration getIdleEventInterval()
setIdleEventInterval
public void setIdleEventInterval(Duration idleEventInterval)
getMonitorInterval
public Duration getMonitorInterval()
setMonitorInterval
public void setMonitorInterval(Duration monitorInterval)
getLogContainerConfig
public Boolean getLogContainerConfig()
setLogContainerConfig
public void setLogContainerConfig(Boolean logContainerConfig)