Package org.apache.kafka.streams
Class TopologyConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.streams.TopologyConfig
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 {@link org.apache.kafka.streams.StreamsBuilder()} method.-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionfinal StreamsConfig
final long
final boolean
final int
final long
final String
final long
final Supplier<TimestampExtractor>
final String
final Properties
Fields inherited from class org.apache.kafka.common.config.AbstractConfig
CONFIG_PROVIDERS_CONFIG
-
Constructor Summary
ConstructorDescriptionTopologyConfig
(String topologyName, StreamsConfig globalAppConfigs, Properties topologyOverrides) TopologyConfig
(StreamsConfig globalAppConfigs) -
Method Summary
Modifier and TypeMethodDescriptionboolean
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
-
Field Details
-
topologyName
-
eosEnabled
public final boolean eosEnabled -
applicationConfigs
-
topologyOverrides
-
maxBufferedSize
public final int maxBufferedSize -
cacheSize
public final long cacheSize -
maxTaskIdleMs
public final long maxTaskIdleMs -
taskTimeoutMs
public final long taskTimeoutMs -
storeType
-
timestampExtractorSupplier
-
deserializationExceptionHandlerSupplier
-
-
Constructor Details
-
TopologyConfig
-
TopologyConfig
public TopologyConfig(String topologyName, StreamsConfig globalAppConfigs, Properties topologyOverrides)
-
-
Method Details
-
parseStoreType
-
isNamedTopology
public boolean isNamedTopology() -
getTaskConfig
-