org.apache.kafka.streams

Class TopologyConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.kafka.streams.TopologyConfig

public class TopologyConfig
extends org.apache.kafka.common.config.AbstractConfig

Streams configs that apply at the topology level. The values in the StreamsConfig parameter of the KafkaStreams or KafkaStreamsNamedTopologyWrapper constructors will determine the defaults, which can then be overridden for specific topologies by passing them in when creating the topology builders via the org.apache.kafka.streams.StreamsBuilder() method.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TopologyConfig.TaskConfig

Field Summary

Fields

Modifier and Type	Field and Description
StreamsConfig	applicationConfigs
long	cacheSize
Supplier<DeserializationExceptionHandler>	deserializationExceptionHandlerSupplier
boolean	eosEnabled
int	maxBufferedSize
long	maxTaskIdleMs
String	storeType
long	taskTimeoutMs
Supplier<TimestampExtractor>	timestampExtractorSupplier
String	topologyName
Properties	topologyOverrides

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor and Description
TopologyConfig(StreamsConfig globalAppConfigs)
TopologyConfig(String topologyName, StreamsConfig globalAppConfigs, Properties topologyOverrides)

Method Summary

Modifier and Type	Method and Description
TopologyConfig.TaskConfig	getTaskConfig()
boolean	isNamedTopology()
Materialized.StoreType	parseStoreType()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

topologyName

public final String topologyName

eosEnabled

public final boolean eosEnabled

applicationConfigs

public final StreamsConfig applicationConfigs

topologyOverrides

public final Properties topologyOverrides

maxBufferedSize

public final int maxBufferedSize

cacheSize

public final long cacheSize

maxTaskIdleMs

public final long maxTaskIdleMs

taskTimeoutMs

public final long taskTimeoutMs

storeType

public final String storeType

timestampExtractorSupplier

public final Supplier<TimestampExtractor> timestampExtractorSupplier

deserializationExceptionHandlerSupplier

public final Supplier<DeserializationExceptionHandler> deserializationExceptionHandlerSupplier

Constructor Detail

TopologyConfig

public TopologyConfig(StreamsConfig globalAppConfigs)

TopologyConfig

public TopologyConfig(String topologyName,
                      StreamsConfig globalAppConfigs,
                      Properties topologyOverrides)

Method Detail

parseStoreType

public Materialized.StoreType parseStoreType()

isNamedTopology

public boolean isNamedTopology()

getTaskConfig

public TopologyConfig.TaskConfig getTaskConfig()