Class KafkaProperties.Streams

java.lang.Object

org.springframework.boot.kafka.autoconfigure.KafkaProperties.Streams

Enclosing class:

KafkaProperties

public static class KafkaProperties.Streams
extends Object

High (and some medium) priority Streams properties and a general properties bucket.

Since:

4.0.0

Author:

Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

Constructor Summary

Constructors

Constructor	Description
Streams()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	buildProperties()
@Nullable String	getApplicationId()
@Nullable List<String>	getBootstrapServers()
KafkaProperties.Cleanup	getCleanup()
@Nullable String	getClientId()
Map<String,String>	getProperties()
@Nullable Integer	getReplicationFactor()
KafkaProperties.Security	getSecurity()
KafkaProperties.Ssl	getSsl()
@Nullable String	getStateDir()
@Nullable DataSize	getStateStoreCacheMaxSize()
boolean	isAutoStartup()
void	setApplicationId(@Nullable String applicationId)
void	setAutoStartup(boolean autoStartup)
void	setBootstrapServers(@Nullable List<String> bootstrapServers)
void	setClientId(@Nullable String clientId)
void	setReplicationFactor(@Nullable Integer replicationFactor)
void	setStateDir(@Nullable String stateDir)
void	setStateStoreCacheMaxSize(@Nullable DataSize stateStoreCacheMaxSize)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Streams

public Streams()

Method Details

getSsl

public KafkaProperties.Ssl getSsl()

getSecurity

public KafkaProperties.Security getSecurity()

getCleanup

public KafkaProperties.Cleanup getCleanup()

getApplicationId

public @Nullable String getApplicationId()

setApplicationId

public void setApplicationId(@Nullable String applicationId)

isAutoStartup

public boolean isAutoStartup()

setAutoStartup

public void setAutoStartup(boolean autoStartup)

getBootstrapServers

public @Nullable List<String> getBootstrapServers()

setBootstrapServers

public void setBootstrapServers(@Nullable List<String> bootstrapServers)

getStateStoreCacheMaxSize

public @Nullable DataSize getStateStoreCacheMaxSize()

setStateStoreCacheMaxSize

public void setStateStoreCacheMaxSize(@Nullable DataSize stateStoreCacheMaxSize)

getClientId

public @Nullable String getClientId()

setClientId

public void setClientId(@Nullable String clientId)

getReplicationFactor

public @Nullable Integer getReplicationFactor()

setReplicationFactor

public void setReplicationFactor(@Nullable Integer replicationFactor)

getStateDir

public @Nullable String getStateDir()

setStateDir

public void setStateDir(@Nullable String stateDir)

getProperties

public Map<String,String> getProperties()

buildProperties

public Map<String,Object> buildProperties()