类 KafkaProperties.Streams
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaProperties.Streams
- 封闭类:
- KafkaProperties
public static class KafkaProperties.Streams extends Object
High (and some medium) priority Streams properties and a general properties bucket.
构造器概要
构造器 构造器 说明 Streams()
方法概要
所有方法 实例方法 具体方法 已过时的方法 修饰符和类型 方法 说明 Map<String,Object>buildProperties()StringgetApplicationId()List<String>getBootstrapServers()IntegergetCacheMaxBytesBuffering()已过时。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)已过时。voidsetCacheMaxSizeBuffering(org.springframework.util.unit.DataSize cacheMaxSizeBuffering)voidsetClientId(String clientId)voidsetReplicationFactor(Integer replicationFactor)voidsetStateDir(String stateDir)
构造器详细资料
Streams
public Streams()
方法详细资料
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()
已过时。
setCacheMaxBytesBuffering
@Deprecated public void setCacheMaxBytesBuffering(Integer cacheMaxBytesBuffering)
已过时。
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()