类 KafkaProperties.Listener
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Listener
- 封闭类:
- KafkaProperties
public static class KafkaProperties.Listener extends Object
嵌套类概要
嵌套类 修饰符和类型 类 说明 static class
KafkaProperties.Listener.Type
构造器概要
构造器 构造器 说明 Listener()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 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)
构造器详细资料
Listener
public Listener()
方法详细资料
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)