org.springframework.boot.autoconfigure.kafka

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 and Description
static class	KafkaProperties.Listener.Type

Constructor Summary

Constructors

Constructor and Description
Listener()

Method Summary

Modifier and Type	Method and 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()
boolean	isMissingTopicsFatal()
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	setMissingTopicsFatal(boolean missingTopicsFatal)
void	setMonitorInterval(Duration monitorInterval)
void	setNoPollThreshold(Float noPollThreshold)
void	setPollTimeout(Duration pollTimeout)
void	setType(KafkaProperties.Listener.Type type)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

isMissingTopicsFatal

public boolean isMissingTopicsFatal()

setMissingTopicsFatal

public void setMissingTopicsFatal(boolean missingTopicsFatal)