org.springframework.boot.autoconfigure.kafka

Class KafkaProperties.Consumer

  • java.lang.Object
    • org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer
    • Constructor Detail

      • Consumer

        public Consumer()
    • Method Detail

      • 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 Integer getFetchMinSize()
      • setFetchMinSize

        public void setFetchMinSize(Integer fetchMinSize)
      • getGroupId

        public String getGroupId()
      • setGroupId

        public void setGroupId(String groupId)
      • getHeartbeatInterval

        public Duration getHeartbeatInterval()
      • setHeartbeatInterval

        public void setHeartbeatInterval(Duration heartbeatInterval)
      • 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)