Class KafkaProperties.Consumer

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

public static class KafkaProperties.Consumer extends Object
  • Constructor Details

    • Consumer

      public Consumer()
  • Method Details

    • getSsl

      public KafkaProperties.Ssl getSsl()
    • getSecurity

      public KafkaProperties.Security getSecurity()
    • getAutoCommitInterval

      public Duration getAutoCommitInterval()
    • setAutoCommitInterval

      public void setAutoCommitInterval(Duration autoCommitInterval)
    • getAutoOffsetReset

      public String getAutoOffsetReset()
    • setAutoOffsetReset

      public void setAutoOffsetReset(String autoOffsetReset)
    • getBootstrapServers

      public List<String> getBootstrapServers()
    • setBootstrapServers

      public void setBootstrapServers(List<String> bootstrapServers)
    • getClientId

      public String getClientId()
    • setClientId

      public void setClientId(String clientId)
    • getEnableAutoCommit

      public Boolean getEnableAutoCommit()
    • setEnableAutoCommit

      public void setEnableAutoCommit(Boolean enableAutoCommit)
    • getFetchMaxWait

      public Duration getFetchMaxWait()
    • setFetchMaxWait

      public void setFetchMaxWait(Duration fetchMaxWait)
    • getFetchMinSize

      public DataSize getFetchMinSize()
    • setFetchMinSize

      public void setFetchMinSize(DataSize fetchMinSize)
    • getGroupId

      public String getGroupId()
    • setGroupId

      public void setGroupId(String groupId)
    • getHeartbeatInterval

      public Duration getHeartbeatInterval()
    • setHeartbeatInterval

      public void setHeartbeatInterval(Duration heartbeatInterval)
    • getIsolationLevel

      public KafkaProperties.IsolationLevel getIsolationLevel()
    • setIsolationLevel

      public void setIsolationLevel(KafkaProperties.IsolationLevel isolationLevel)
    • getKeyDeserializer

      public Class<?> getKeyDeserializer()
    • setKeyDeserializer

      public void setKeyDeserializer(Class<?> keyDeserializer)
    • getValueDeserializer

      public Class<?> getValueDeserializer()
    • setValueDeserializer

      public void setValueDeserializer(Class<?> valueDeserializer)
    • getMaxPollRecords

      public Integer getMaxPollRecords()
    • setMaxPollRecords

      public void setMaxPollRecords(Integer maxPollRecords)
    • getProperties

      public Map<String,String> getProperties()
    • buildProperties

      public Map<String,Object> buildProperties()