Class KafkaProperties.Streams
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Streams
- Enclosing class:
- KafkaProperties
public static class KafkaProperties.Streams extends Object
High (and some medium) priority Streams properties and a general properties bucket.
Constructor Summary
Constructors Constructor Description Streams()
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description Map<String,Object>buildProperties()StringgetApplicationId()List<String>getBootstrapServers()IntegergetCacheMaxBytesBuffering()Deprecated.org.springframework.util.unit.DataSizegetCacheMaxSizeBuffering()StringgetClientId()Map<String,String>getProperties()IntegergetReplicationFactor()KafkaProperties.SslgetSsl()StringgetStateDir()booleanisAutoStartup()voidsetApplicationId(String applicationId)voidsetAutoStartup(boolean autoStartup)voidsetBootstrapServers(List<String> bootstrapServers)voidsetCacheMaxBytesBuffering(Integer cacheMaxBytesBuffering)Deprecated.voidsetCacheMaxSizeBuffering(org.springframework.util.unit.DataSize cacheMaxSizeBuffering)voidsetClientId(String clientId)voidsetReplicationFactor(Integer replicationFactor)voidsetStateDir(String stateDir)
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)
getCacheMaxBytesBuffering
@DeprecatedConfigurationProperty(replacement="spring.kafka.streams.cache-max-size-buffering") @Deprecated public Integer getCacheMaxBytesBuffering()
Deprecated.
setCacheMaxBytesBuffering
@Deprecated public void setCacheMaxBytesBuffering(Integer cacheMaxBytesBuffering)
Deprecated.
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()