类 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()
String
getApplicationId()
List<String>
getBootstrapServers()
Integer
getCacheMaxBytesBuffering()
已过时。org.springframework.util.unit.DataSize
getCacheMaxSizeBuffering()
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
setCacheMaxSizeBuffering(org.springframework.util.unit.DataSize cacheMaxSizeBuffering)
void
setClientId(String clientId)
void
setReplicationFactor(Integer replicationFactor)
void
setStateDir(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()