Class KafkaStreamsConfig


  • public class KafkaStreamsConfig
    extends Object
    • Constructor Detail

      • KafkaStreamsConfig

        public KafkaStreamsConfig()
    • Method Detail

      • getApplicationId

        public String getApplicationId()
      • setApplicationId

        public void setApplicationId​(String applicationId)
      • getBootstrapServers

        public String getBootstrapServers()
      • setBootstrapServers

        public void setBootstrapServers​(String bootstrapServers)
      • getProcessingGuarantee

        public String getProcessingGuarantee()
      • setProcessingGuarantee

        public void setProcessingGuarantee​(String processingGuarantee)
      • getReplicationFactor

        public int getReplicationFactor()
      • setReplicationFactor

        public void setReplicationFactor​(int replicationFactor)
      • isCleanUp

        public boolean isCleanUp()
      • setCleanUp

        public void setCleanUp​(boolean cleanUp)