程序包 org.springframework.boot.autoconfigure.kafka

类 KafkaProperties.Consumer

java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Consumer
封闭类:
KafkaProperties
public static class KafkaProperties.Consumer extends Object

  • 构造器详细资料

    • Consumer

      public Consumer()

  • 方法详细资料

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

    • getMaxPollInterval

      public Duration getMaxPollInterval()

    • setMaxPollInterval

      public void setMaxPollInterval(Duration maxPollInterval)

    • getProperties

      public Map<String,String> getProperties()

    • buildProperties

      public Map<String,Object> buildProperties(SslBundles sslBundles)