Class TopologyConfig

Namespace

Org.Apache.Kafka.Streams

Assembly

MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html

public class TopologyConfig : AbstractConfig, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition

Inheritance

object

DynamicObject

JVMBridgeBase

JVMBridgeBase<AbstractConfig>

AbstractConfig

TopologyConfig

Implements

IDynamicMetaObjectProvider

IJVMBridgeCore

IEquatable<IJVMBridgeBaseInstance>

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeBaseInstance

IJVMBridgeDefinition

Inherited Members

AbstractConfig.CreatePoolableInstance(ConfigDef, Map<object, object>, bool)

AbstractConfig.CreatePoolableInstance(ConfigDef, Map<object, object>, Map<String, object>, bool)

AbstractConfig.CreatePoolableInstance(ConfigDef, Map<object, object>)

AbstractConfig.AUTOMATIC_CONFIG_PROVIDERS_PROPERTY

AbstractConfig.CONFIG_PROVIDERS_CONFIG

AbstractConfig.CONFIG_PROVIDERS_DOC

AbstractConfig.GetConfiguredInstances<T>(String, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstances<T>(String, Class)

AbstractConfig.GetConfiguredInstances<T>(List<String>, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstance<T>(String, Class, Map<String, object>)

AbstractConfig.GetConfiguredInstance<T>(String, Class)

AbstractConfig.GetBoolean(String)

AbstractConfig.GetClass(String)

AbstractConfig.GetDouble(String)

AbstractConfig.GetInt(String)

AbstractConfig.GetLong(String)

AbstractConfig.GetShort(String)

AbstractConfig.DocumentationOf(String)

AbstractConfig.GetString(String)

AbstractConfig.GetList(String)

AbstractConfig.NonInternalValues()

AbstractConfig.Values()

AbstractConfig.Originals()

AbstractConfig.Originals(Map<String, object>)

AbstractConfig.OriginalsWithPrefix(String, bool)

AbstractConfig.OriginalsWithPrefix(String)

AbstractConfig.ValuesWithPrefixAllOrNothing(String)

AbstractConfig.ValuesWithPrefixOverride(String)

AbstractConfig.OriginalsStrings()

AbstractConfig.Unused()

AbstractConfig.TypeOf(String)

AbstractConfig.GetPassword(String)

AbstractConfig.Ignore(String)

AbstractConfig.LogUnused()

Constructors

TopologyConfig(String, StreamsConfig, Properties)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#%3Cinit%3E(java.lang.String,org.apache.kafka.streams.StreamsConfig,java.util.Properties)

public TopologyConfig(String arg0, StreamsConfig arg1, Properties arg2)

Parameters

arg0 String

String

arg1 StreamsConfig

StreamsConfig

arg2 Properties

Properties

TopologyConfig(IJVMBridgeBaseInitializer)

Initializer used internally by JCOBridge. Do not use directly.

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public TopologyConfig(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

TopologyConfig(StreamsConfig)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#%3Cinit%3E(org.apache.kafka.streams.StreamsConfig)

public TopologyConfig(StreamsConfig arg0)

Parameters

arg0 StreamsConfig

StreamsConfig

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

GetTaskConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#getTaskConfig()

public TopologyConfig.TaskConfig GetTaskConfig { get; }

Property Value

TopologyConfig.TaskConfig

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements java.lang.AutoCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

applicationConfigs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#applicationConfigs

public StreamsConfig applicationConfigs { get; set; }

Property Value

StreamsConfig

cacheSize

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#cacheSize

public long cacheSize { get; set; }

Property Value

long

deserializationExceptionHandlerSupplier

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#deserializationExceptionHandlerSupplier

public Supplier deserializationExceptionHandlerSupplier { get; set; }

Property Value

Supplier

dslStoreSuppliers

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#dslStoreSuppliers

public Class dslStoreSuppliers { get; set; }

Property Value

Class

ensureExplicitInternalResourceNaming

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#ensureExplicitInternalResourceNaming

public bool ensureExplicitInternalResourceNaming { get; set; }

Property Value

bool

eosEnabled

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#eosEnabled

public bool eosEnabled { get; set; }

Property Value

bool

maxBufferedSize

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#maxBufferedSize

public int maxBufferedSize { get; set; }

Property Value

int

maxTaskIdleMs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#maxTaskIdleMs

public long maxTaskIdleMs { get; set; }

Property Value

long

processingExceptionHandlerSupplier

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#processingExceptionHandlerSupplier

public Supplier processingExceptionHandlerSupplier { get; set; }

Property Value

Supplier

storeType

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#storeType

public String storeType { get; set; }

Property Value

String

taskTimeoutMs

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#taskTimeoutMs

public long taskTimeoutMs { get; set; }

Property Value

long

timestampExtractorSupplier

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#timestampExtractorSupplier

public Supplier timestampExtractorSupplier { get; set; }

Property Value

Supplier

topologyName

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#topologyName

public String topologyName { get; set; }

Property Value

String

topologyOverrides

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#topologyOverrides

public Properties topologyOverrides { get; set; }

Property Value

Properties

Methods

CreatePoolableInstance(String, StreamsConfig, Properties)

HPA initializer for TopologyConfig(Java.Lang.String arg0, Org.Apache.Kafka.Streams.StreamsConfig arg1, Java.Util.Properties arg2)

public static TopologyConfig CreatePoolableInstance(String arg0, StreamsConfig arg1, Properties arg2)

Parameters

arg0 String

arg1 StreamsConfig

arg2 Properties

Returns

TopologyConfig

CreatePoolableInstance(StreamsConfig)

HPA initializer for TopologyConfig(Org.Apache.Kafka.Streams.StreamsConfig arg0)

public static TopologyConfig CreatePoolableInstance(StreamsConfig arg0)

Parameters

arg0 StreamsConfig

Returns

TopologyConfig

IsNamedTopology()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#isNamedTopology()

public bool IsNamedTopology()

Returns

bool

bool

ParseStoreType()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#parseStoreType()

[Obsolete("Deprecated in JVM")]
public Materialized.StoreType ParseStoreType()

Returns

Materialized.StoreType

Materialized.StoreType

ResolveDslStoreSuppliers()

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/TopologyConfig.html#resolveDslStoreSuppliers()

public Optional<DslStoreSuppliers> ResolveDslStoreSuppliers()

Returns

Optional<DslStoreSuppliers>

Optional