Class TopologyConfig

Namespace

MASES.KNet.Streams

Assembly

MASES.KNet.dll

KNet implementation of TopologyConfig

public class TopologyConfig : IGenericSerDesFactoryApplier

Inheritance

object

TopologyConfig

Implements

IGenericSerDesFactoryApplier

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Constructors

TopologyConfig(StreamsConfigBuilder)

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

public TopologyConfig(StreamsConfigBuilder arg0)

Parameters

arg0 StreamsConfigBuilder

StreamsConfigBuilder

TopologyConfig(string, StreamsConfigBuilder, Properties)

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

public TopologyConfig(string arg0, StreamsConfigBuilder arg1, Properties arg2)

Parameters

arg0 string

string

arg1 StreamsConfigBuilder

StreamsConfigBuilder

arg2 Properties

Properties

Properties

ApplicationConfigs

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

public StreamsConfig ApplicationConfigs { get; }

Property Value

StreamsConfig

CacheSize

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

public long CacheSize { get; }

Property Value

long

DeserializationExceptionHandlerSupplier

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

public Supplier DeserializationExceptionHandlerSupplier { get; }

Property Value

Supplier

EosEnabled

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

public bool EosEnabled { get; }

Property Value

bool

IsNamedTopology

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

public bool IsNamedTopology { get; }

Property Value

bool

MaxBufferedSize

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

public int MaxBufferedSize { get; }

Property Value

int

MaxTaskIdleMs

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

public long MaxTaskIdleMs { get; }

Property Value

long

OverrideProperties

If set, this Func<T, TResult> will be called from PrepareProperties(StreamsConfigBuilder)

public static Func<StreamsConfigBuilder, Properties> OverrideProperties { get; set; }

Property Value

Func<StreamsConfigBuilder, Properties>

ResolveDslStoreSuppliers

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

public DslStoreSuppliers ResolveDslStoreSuppliers { get; }

Property Value

DslStoreSuppliers

StoreType

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

public string StoreType { get; }

Property Value

string

TaskConfig

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

public TopologyConfig.TaskConfig TaskConfig { get; }

Property Value

TopologyConfig.TaskConfig

TaskTimeoutMs

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

public long TaskTimeoutMs { get; }

Property Value

long

TimestampExtractorSupplier

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

public Supplier TimestampExtractorSupplier { get; }

Property Value

Supplier

TopologyName

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

public string TopologyName { get; }

Property Value

string

TopologyOverrides

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

public Properties TopologyOverrides { get; }

Property Value

Properties

Methods

PrepareProperties(StreamsConfigBuilder)

Override this method to check and modify the Properties returned to underlying KafkaStreams

protected virtual Properties PrepareProperties(StreamsConfigBuilder builder)

Parameters

builder StreamsConfigBuilder

StreamsConfigBuilder to use to return Properties

Returns

Properties

Properties used from underlying KafkaStreams

Operators

implicit operator TopologyConfig(TopologyConfig)

Converter from TopologyConfig to TopologyConfig

public static implicit operator TopologyConfig(TopologyConfig t)

Parameters

t TopologyConfig

Returns

TopologyConfig