Class KafkaProperties.Listener
java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Listener
- Enclosing class:
- KafkaProperties
-
Nested Class Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.kafka.listener.ContainerProperties.AckMode
getType()
boolean
boolean
boolean
boolean
void
setAckCount
(Integer ackCount) void
setAckMode
(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode) void
setAckTime
(Duration ackTime) void
setAsyncAcks
(Boolean asyncAcks) void
setAutoStartup
(boolean autoStartup) void
setChangeConsumerThreadName
(Boolean changeConsumerThreadName) void
setClientId
(String clientId) void
setConcurrency
(Integer concurrency) void
setIdleBetweenPolls
(Duration idleBetweenPolls) void
setIdleEventInterval
(Duration idleEventInterval) void
setIdlePartitionEventInterval
(Duration idlePartitionEventInterval) void
setImmediateStop
(boolean immediateStop) void
setLogContainerConfig
(Boolean logContainerConfig) void
setMissingTopicsFatal
(boolean missingTopicsFatal) void
setMonitorInterval
(Duration monitorInterval) void
setNoPollThreshold
(Float noPollThreshold) void
setObservationEnabled
(boolean observationEnabled) void
setPollTimeout
(Duration pollTimeout) void
-
Constructor Details
-
Listener
public Listener()
-
-
Method Details
-
getType
-
setType
-
getAckMode
public org.springframework.kafka.listener.ContainerProperties.AckMode getAckMode() -
setAckMode
public void setAckMode(org.springframework.kafka.listener.ContainerProperties.AckMode ackMode) -
getAsyncAcks
-
setAsyncAcks
-
getClientId
-
setClientId
-
getConcurrency
-
setConcurrency
-
getPollTimeout
-
setPollTimeout
-
getNoPollThreshold
-
setNoPollThreshold
-
getAckCount
-
setAckCount
-
getAckTime
-
setAckTime
-
getIdleBetweenPolls
-
setIdleBetweenPolls
-
getIdleEventInterval
-
setIdleEventInterval
-
getIdlePartitionEventInterval
-
setIdlePartitionEventInterval
-
getMonitorInterval
-
setMonitorInterval
-
getLogContainerConfig
-
setLogContainerConfig
-
isMissingTopicsFatal
public boolean isMissingTopicsFatal() -
setMissingTopicsFatal
public void setMissingTopicsFatal(boolean missingTopicsFatal) -
isImmediateStop
public boolean isImmediateStop() -
setImmediateStop
public void setImmediateStop(boolean immediateStop) -
isAutoStartup
public boolean isAutoStartup() -
setAutoStartup
public void setAutoStartup(boolean autoStartup) -
getChangeConsumerThreadName
-
setChangeConsumerThreadName
-
isObservationEnabled
public boolean isObservationEnabled() -
setObservationEnabled
public void setObservationEnabled(boolean observationEnabled)
-