Constructor Detail

• Streams

  public Streams()

Method Detail

• getSsl

  public KafkaProperties.Ssl getSsl()

• getApplicationId

  public String getApplicationId()

• setApplicationId

  public void setApplicationId(String applicationId)

• isAutoStartup

  public boolean isAutoStartup()

• setAutoStartup

  public void setAutoStartup(boolean autoStartup)

• getBootstrapServers

  public List<String> getBootstrapServers()

• setBootstrapServers

  public void setBootstrapServers(List<String> bootstrapServers)

• getCacheMaxSizeBuffering

  public org.springframework.util.unit.DataSize getCacheMaxSizeBuffering()

• setCacheMaxSizeBuffering

  public void setCacheMaxSizeBuffering(org.springframework.util.unit.DataSize cacheMaxSizeBuffering)

• getClientId

  public String getClientId()

• setClientId

  public void setClientId(String clientId)

• getReplicationFactor

  public Integer getReplicationFactor()

• setReplicationFactor

  public void setReplicationFactor(Integer replicationFactor)

• getStateDir

  public String getStateDir()

• setStateDir

  public void setStateDir(String stateDir)

• getProperties

  public Map<String,String> getProperties()

• buildProperties

  public Map<String,Object> buildProperties()