public static class KafkaProperties.Streams extends Object
Constructor and Description |
---|
Streams() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
buildProperties() |
String |
getApplicationId() |
List<String> |
getBootstrapServers() |
Integer |
getCacheMaxBytesBuffering() |
String |
getClientId() |
Map<String,String> |
getProperties() |
Integer |
getReplicationFactor() |
KafkaProperties.Ssl |
getSsl() |
String |
getStateDir() |
boolean |
isAutoStartup() |
void |
setApplicationId(String applicationId) |
void |
setAutoStartup(boolean autoStartup) |
void |
setBootstrapServers(List<String> bootstrapServers) |
void |
setCacheMaxBytesBuffering(Integer cacheMaxBytesBuffering) |
void |
setClientId(String clientId) |
void |
setReplicationFactor(Integer replicationFactor) |
void |
setStateDir(String stateDir) |
public KafkaProperties.Ssl getSsl()
public String getApplicationId()
public void setApplicationId(String applicationId)
public boolean isAutoStartup()
public void setAutoStartup(boolean autoStartup)
public Integer getCacheMaxBytesBuffering()
public void setCacheMaxBytesBuffering(Integer cacheMaxBytesBuffering)
public String getClientId()
public void setClientId(String clientId)
public Integer getReplicationFactor()
public void setReplicationFactor(Integer replicationFactor)
public String getStateDir()
public void setStateDir(String stateDir)
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.