Class TopologyConfig.TaskConfig

java.lang.Object
org.apache.kafka.streams.TopologyConfig.TaskConfig
Enclosing class:
TopologyConfig

public static class TopologyConfig.TaskConfig extends Object
  • Field Details

    • maxTaskIdleMs

      public final long maxTaskIdleMs
    • taskTimeoutMs

      public final long taskTimeoutMs
    • maxBufferedSize

      public final int maxBufferedSize
    • timestampExtractor

      public final TimestampExtractor timestampExtractor
    • deserializationExceptionHandler

      public final DeserializationExceptionHandler deserializationExceptionHandler
    • eosEnabled

      public final boolean eosEnabled