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