Table of Contents

Class TopologyConfig

Namespace
MASES.KNet.Streams
Assembly
MASES.KNet.dll

KNet implementation of TopologyConfig

public class TopologyConfig : IGenericSerDesFactoryApplier
Inheritance
TopologyConfig
Implements
Inherited Members

Constructors

TopologyConfig(StreamsConfigBuilder)

public TopologyConfig(StreamsConfigBuilder arg0)

Parameters

arg0 StreamsConfigBuilder

StreamsConfigBuilder

TopologyConfig(string, StreamsConfigBuilder, Properties)

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

Parameters

arg0 string

string

arg1 StreamsConfigBuilder

StreamsConfigBuilder

arg2 Properties

Properties

Properties

ApplicationConfigs

public StreamsConfig ApplicationConfigs { get; }

Property Value

StreamsConfig

CacheSize

public long CacheSize { get; }

Property Value

long

DeserializationExceptionHandlerSupplier

public Supplier DeserializationExceptionHandlerSupplier { get; }

Property Value

Supplier

EosEnabled

public bool EosEnabled { get; }

Property Value

bool

IsNamedTopology

public bool IsNamedTopology { get; }

Property Value

bool

MaxBufferedSize

public int MaxBufferedSize { get; }

Property Value

int

MaxTaskIdleMs

public long MaxTaskIdleMs { get; }

Property Value

long

OverrideProperties

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

Property Value

Func<StreamsConfigBuilder, Properties>

ResolveDslStoreSuppliers

public DslStoreSuppliers ResolveDslStoreSuppliers { get; }

Property Value

DslStoreSuppliers

StoreType

public string StoreType { get; }

Property Value

string

TaskConfig

public TopologyConfig.TaskConfig TaskConfig { get; }

Property Value

TopologyConfig.TaskConfig

TaskTimeoutMs

public long TaskTimeoutMs { get; }

Property Value

long

TimestampExtractorSupplier

public Supplier TimestampExtractorSupplier { get; }

Property Value

Supplier

TopologyName

public string TopologyName { get; }

Property Value

string

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