Class KafkaProperties.Listener

java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Listener
Enclosing class:
KafkaProperties

public static class KafkaProperties.Listener extends Object
  • Constructor Details

    • Listener

      public Listener()
  • Method Details

    • 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)
    • getIdleBetweenPolls

      public Duration getIdleBetweenPolls()
    • setIdleBetweenPolls

      public void setIdleBetweenPolls(Duration idleBetweenPolls)
    • getIdleEventInterval

      public Duration getIdleEventInterval()
    • setIdleEventInterval

      public void setIdleEventInterval(Duration idleEventInterval)
    • getIdlePartitionEventInterval

      public Duration getIdlePartitionEventInterval()
    • setIdlePartitionEventInterval

      public void setIdlePartitionEventInterval(Duration idlePartitionEventInterval)
    • 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)
    • isImmediateStop

      public boolean isImmediateStop()
    • setImmediateStop

      public void setImmediateStop(boolean immediateStop)