Package org.apache.kafka.streams

Class TopologyConfig.TaskConfig

java.lang.Object
org.apache.kafka.streams.TopologyConfig.TaskConfig
Enclosing class:
TopologyConfig
public static class TopologyConfig.TaskConfigextends 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

    • processingExceptionHandler

      public final ProcessingExceptionHandler processingExceptionHandler

    • eosEnabled

      public final boolean eosEnabled