Class KafkaProperties.Streams
java.lang.Object
org.springframework.boot.autoconfigure.kafka.KafkaProperties.Streams
- Enclosing class:
- KafkaProperties
High (and some medium) priority Streams properties and a general properties bucket.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionbuildProperties
(SslBundles sslBundles) Deprecated, for removal: This API element is subject to removal in a future version.getSsl()
boolean
void
setApplicationId
(String applicationId) void
setAutoStartup
(boolean autoStartup) void
setBootstrapServers
(List<String> bootstrapServers) void
setCacheMaxSizeBuffering
(DataSize cacheMaxSizeBuffering) Deprecated, for removal: This API element is subject to removal in a future version.void
setClientId
(String clientId) void
setReplicationFactor
(Integer replicationFactor) void
setStateDir
(String stateDir) void
setStateStoreCacheMaxSize
(DataSize stateStoreCacheMaxSize)
-
Constructor Details
-
Streams
public Streams()
-
-
Method Details
-
getSsl
-
getSecurity
-
getCleanup
-
getApplicationId
-
setApplicationId
-
isAutoStartup
public boolean isAutoStartup() -
setAutoStartup
public void setAutoStartup(boolean autoStartup) -
getBootstrapServers
-
setBootstrapServers
-
getCacheMaxSizeBuffering
@DeprecatedConfigurationProperty(replacement="spring.kafka.streams.state-store-cache-max-size", since="3.1.0") @Deprecated(since="3.1.0", forRemoval=true) public DataSize getCacheMaxSizeBuffering()Deprecated, for removal: This API element is subject to removal in a future version. -
setCacheMaxSizeBuffering
@Deprecated(since="3.1.0", forRemoval=true) public void setCacheMaxSizeBuffering(DataSize cacheMaxSizeBuffering) Deprecated, for removal: This API element is subject to removal in a future version. -
getStateStoreCacheMaxSize
-
setStateStoreCacheMaxSize
-
getClientId
-
setClientId
-
getReplicationFactor
-
setReplicationFactor
-
getStateDir
-
setStateDir
-
getProperties
-
buildProperties
-