org.springframework.boot.autoconfigure.kafka

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 and Description
Streams()

Method Summary

Modifier and Type	Method and Description
Map<String,Object>	buildProperties()
String	getApplicationId()
List<String>	getBootstrapServers()
Integer	getCacheMaxBytesBuffering() Deprecated.
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) Deprecated.
void	setCacheMaxSizeBuffering(DataSize cacheMaxSizeBuffering)
void	setClientId(String clientId)
void	setReplicationFactor(Integer replicationFactor)
void	setStateDir(String stateDir)

Methods inherited from class java.lang.Object

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

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 DataSize getCacheMaxSizeBuffering()

setCacheMaxSizeBuffering

public void setCacheMaxSizeBuffering(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()