public static class KafkaProperties.Listener extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KafkaProperties.Listener.Type |
Constructor and Description |
---|
Listener() |
public KafkaProperties.Listener.Type getType()
public void setType(KafkaProperties.Listener.Type type)
public org.springframework.kafka.listener.ContainerProperties.AckMode getAckMode()
public void setAckMode(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode)
public String getClientId()
public void setClientId(String clientId)
public Integer getConcurrency()
public void setConcurrency(Integer concurrency)
public Duration getPollTimeout()
public void setPollTimeout(Duration pollTimeout)
public Float getNoPollThreshold()
public void setNoPollThreshold(Float noPollThreshold)
public Integer getAckCount()
public void setAckCount(Integer ackCount)
public Duration getAckTime()
public void setAckTime(Duration ackTime)
public Duration getIdleEventInterval()
public void setIdleEventInterval(Duration idleEventInterval)
public Duration getMonitorInterval()
public void setMonitorInterval(Duration monitorInterval)
public Boolean getLogContainerConfig()
public void setLogContainerConfig(Boolean logContainerConfig)
public boolean isMissingTopicsFatal()
public void setMissingTopicsFatal(boolean missingTopicsFatal)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.