Package org.apache.kafka.streams

Class TopologyConfig.TaskConfig

java.lang.Object

org.apache.kafka.streams.TopologyConfig.TaskConfig

Enclosing class:

TopologyConfig

public static class TopologyConfig.TaskConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final DeserializationExceptionHandler	deserializationExceptionHandler
final boolean	eosEnabled
final int	maxBufferedSize
final long	maxTaskIdleMs
final ProcessingExceptionHandler	processingExceptionHandler
final long	taskTimeoutMs
final TimestampExtractor	timestampExtractor

Method Summary

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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