public static class KafkaProperties.Streams extends ObjectSE
コンストラクターと説明 |
---|
Streams() |
修飾子と型 | メソッドと説明 |
---|---|
MapSE<StringSE, ObjectSE> | buildProperties() |
StringSE | getApplicationId() |
ListSE<StringSE> | getBootstrapServers() |
DataSize | getCacheMaxSizeBuffering() |
KafkaProperties.Cleanup | getCleanup() |
StringSE | getClientId() |
MapSE<StringSE, StringSE> | getProperties() |
IntegerSE | getReplicationFactor() |
KafkaProperties.Security | getSecurity() |
KafkaProperties.Ssl | getSsl() |
StringSE | getStateDir() |
boolean | isAutoStartup() |
void | setApplicationId(StringSE applicationId) |
void | setAutoStartup(boolean autoStartup) |
void | setBootstrapServers(ListSE<StringSE> bootstrapServers) |
void | setCacheMaxSizeBuffering(DataSize cacheMaxSizeBuffering) |
void | setClientId(StringSE clientId) |
void | setReplicationFactor(IntegerSE replicationFactor) |
void | setStateDir(StringSE stateDir) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public KafkaProperties.Ssl getSsl()
public KafkaProperties.Security getSecurity()
public KafkaProperties.Cleanup getCleanup()
public StringSE getApplicationId()
public void setApplicationId(StringSE applicationId)
public boolean isAutoStartup()
public void setAutoStartup(boolean autoStartup)
public DataSize getCacheMaxSizeBuffering()
public void setCacheMaxSizeBuffering(DataSize cacheMaxSizeBuffering)
public StringSE getClientId()
public void setClientId(StringSE clientId)
public IntegerSE getReplicationFactor()
public void setReplicationFactor(IntegerSE replicationFactor)
public StringSE getStateDir()
public void setStateDir(StringSE stateDir)