类 KafkaProperties.Consumer

构造器详细资料

• Consumer

  public Consumer()

方法详细资料

• getSsl

  public KafkaProperties.Ssl getSsl()

• 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 org.springframework.util.unit.DataSize getFetchMinSize()

• setFetchMinSize

  public void setFetchMinSize​(org.springframework.util.unit.DataSize 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)

• getProperties

  public Map<String,​String> getProperties()

• buildProperties

  public Map<String,​Object> buildProperties()