Class CleanupConfig


  • public class CleanupConfig
    extends java.lang.Object
    Specifies time of KafkaStreams.cleanUp() execution.
    Author:
    Pawel Szymczyk
    • Constructor Detail

      • CleanupConfig

        public CleanupConfig()
      • CleanupConfig

        public CleanupConfig​(boolean onStart,
                             boolean onStop)
    • Method Detail

      • cleanupOnStart

        public boolean cleanupOnStart()
      • cleanupOnStop

        public boolean cleanupOnStop()