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 and Description
DeserializationExceptionHandler	deserializationExceptionHandler
boolean	eosEnabled
int	maxBufferedSize
long	maxTaskIdleMs
long	taskTimeoutMs
TimestampExtractor	timestampExtractor

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

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