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()
DataSize	getCacheMaxSizeBuffering()
String	getClientId()
Map<String,String>	getProperties()
Integer	getReplicationFactor()
KafkaProperties.Security	getSecurity()
KafkaProperties.Ssl	getSsl()
String	getStateDir()
boolean	isAutoStartup()
void	setApplicationId(String applicationId)
void	setAutoStartup(boolean autoStartup)
void	setBootstrapServers(List<String> bootstrapServers)
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()

getSecurity

public KafkaProperties.Security getSecurity()

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)

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