Class KafkaProperties.Consumer

java.lang.Object
org.springframework.boot.kafka.autoconfigure.KafkaProperties.Consumer
Enclosing class:
KafkaProperties
public static class KafkaProperties.Consumer extends Object
Since:
4.0.0
Author:
Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

  • Constructor Details

    • Consumer

      public Consumer()

  • Method Details

    • getSsl

      public KafkaProperties.Ssl getSsl()

    • getSecurity

      public KafkaProperties.Security getSecurity()

    • getAutoCommitInterval

      public @Nullable Duration getAutoCommitInterval()

    • setAutoCommitInterval

      public void setAutoCommitInterval(@Nullable Duration autoCommitInterval)

    • getAutoOffsetReset

      public @Nullable String getAutoOffsetReset()

    • setAutoOffsetReset

      public void setAutoOffsetReset(@Nullable String autoOffsetReset)

    • getBootstrapServers

      public @Nullable List<String> getBootstrapServers()

    • setBootstrapServers

      public void setBootstrapServers(@Nullable List<String> bootstrapServers)

    • getClientId

      public @Nullable String getClientId()

    • setClientId

      public void setClientId(@Nullable String clientId)

    • getEnableAutoCommit

      public @Nullable Boolean getEnableAutoCommit()

    • setEnableAutoCommit

      public void setEnableAutoCommit(@Nullable Boolean enableAutoCommit)

    • getFetchMaxWait

      public @Nullable Duration getFetchMaxWait()

    • setFetchMaxWait

      public void setFetchMaxWait(@Nullable Duration fetchMaxWait)

    • getFetchMinSize

      public @Nullable DataSize getFetchMinSize()

    • setFetchMinSize

      public void setFetchMinSize(@Nullable DataSize fetchMinSize)

    • getGroupId

      public @Nullable String getGroupId()

    • setGroupId

      public void setGroupId(@Nullable String groupId)

    • getHeartbeatInterval

      public @Nullable Duration getHeartbeatInterval()

    • setHeartbeatInterval

      public void setHeartbeatInterval(@Nullable 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 @Nullable Integer getMaxPollRecords()

    • setMaxPollRecords

      public void setMaxPollRecords(@Nullable Integer maxPollRecords)

    • getMaxPollInterval

      public @Nullable Duration getMaxPollInterval()

    • setMaxPollInterval

      public void setMaxPollInterval(@Nullable Duration maxPollInterval)

    • getProperties

      public Map<String,String> getProperties()

    • buildProperties

      public Map<String,Object> buildProperties()