Class CleanupConfig

java.lang.Object
org.springframework.kafka.core.CleanupConfig

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

    • CleanupConfig

      public CleanupConfig()
    • CleanupConfig

      public CleanupConfig(boolean onStart, boolean onStop)
  • Method Details

    • cleanupOnStart

      public boolean cleanupOnStart()
    • cleanupOnStop

      public boolean cleanupOnStop()