Table of Contents

Class KNetStreams

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

KNet extension of KafkaStreams

public class KNetStreams : IGenericSerDesFactoryApplier
Inheritance
KNetStreams
Implements
Inherited Members

Constructors

KNetStreams(Topology, StreamsConfigBuilder)

public KNetStreams(Topology arg0, StreamsConfigBuilder arg1)

Parameters

arg0 Topology

Topology

arg1 StreamsConfigBuilder

StreamsConfigBuilder

KNetStreams(Topology, StreamsConfigBuilder, KNetClientSupplier)

public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, KNetClientSupplier arg2)

Parameters

arg0 Topology

Topology

arg1 StreamsConfigBuilder

StreamsConfigBuilder

arg2 KNetClientSupplier

KNetClientSupplier

KNetStreams(Topology, StreamsConfigBuilder, KNetClientSupplier, Time)

public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, KNetClientSupplier arg2, Time arg3)

Parameters

arg0 Topology

Topology

arg1 StreamsConfigBuilder

StreamsConfigBuilder

arg2 KNetClientSupplier

KNetClientSupplier

arg3 Time

Time

KNetStreams(Topology, StreamsConfigBuilder, Time)

public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, Time arg2)

Parameters

arg0 Topology

Topology

arg1 StreamsConfigBuilder

StreamsConfigBuilder

arg2 Time

Time

Properties

AllLocalStorePartitionLags

public Map<String, Map<Integer, LagInfo>> AllLocalStorePartitionLags { get; }

Property Value

Map<String, Map<Integer, LagInfo>>

Map

IsPaused

public bool IsPaused { get; }

Property Value

bool

bool

MetadataForAllStreamsClients

public Collection<StreamsMetadata> MetadataForAllStreamsClients { get; }

Property Value

Collection<StreamsMetadata>

Collection

MetadataForLocalThreads

public Set<ThreadMetadata> MetadataForLocalThreads { get; }

Property Value

Set<ThreadMetadata>

Set

OverrideProperties

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

Property Value

Func<StreamsConfigBuilder, Properties>

State

public KafkaStreams.State State { get; }

Property Value

KafkaStreams.State

KafkaStreams.State

Methods

AddStreamThread()

public Optional<String> AddStreamThread()

Returns

Optional<String>

Optional

CleanUp()

public void CleanUp()

ClientInstanceIds(Duration)

public ClientInstanceIds ClientInstanceIds(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

ClientInstanceIds

ClientInstanceIds

Close()

public void Close()

Close(Duration)

public bool Close(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

bool

bool

Exceptions

IllegalArgumentException

Close(CloseOptions)

public bool Close(KafkaStreams.CloseOptions arg0)

Parameters

arg0 KafkaStreams.CloseOptions

KafkaStreams.CloseOptions

Returns

bool

bool

Exceptions

IllegalArgumentException

Close(TimeSpan)

public bool Close(TimeSpan arg0)

Parameters

arg0 TimeSpan

Returns

bool

Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>()

public Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric> Metrics<ReturnExtendsOrg_Apache_Kafka_Common_Metric>() where ReturnExtendsOrg_Apache_Kafka_Common_Metric : Metric

Returns

Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>

Map

Type Parameters

ReturnExtendsOrg_Apache_Kafka_Common_Metric

Metric

Pause()

public void Pause()

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

QueryMetadataForKey<K>(string, K, ISerializer<K, byte[]>)

public KeyQueryMetadata QueryMetadataForKey<K>(string arg0, K arg1, ISerializer<K, byte[]> arg2)

Parameters

arg0 string

String

arg1 K

K

arg2 ISerializer<K, byte[]>

Serializer

Returns

KeyQueryMetadata

KeyQueryMetadata

Type Parameters

K

QueryMetadataForKey<K>(string, K, StreamPartitioner<K, object>)

public KeyQueryMetadata QueryMetadataForKey<K>(string arg0, K arg1, StreamPartitioner<K, object> arg2)

Parameters

arg0 string

String

arg1 K

K

arg2 StreamPartitioner<K, object>

Serializer

Returns

KeyQueryMetadata

KeyQueryMetadata

Type Parameters

K

QueryMetadataForKey<K, TJVMK>(string, K, ISerializer<K, TJVMK>)

public KeyQueryMetadata QueryMetadataForKey<K, TJVMK>(string arg0, K arg1, ISerializer<K, TJVMK> arg2)

Parameters

arg0 string

String

arg1 K

K

arg2 ISerializer<K, TJVMK>

Serializer

Returns

KeyQueryMetadata

KeyQueryMetadata

Type Parameters

K
TJVMK

QueryMetadataForKey<K, TJVMK>(string, K, StreamPartitioner<K, object>)

public KeyQueryMetadata QueryMetadataForKey<K, TJVMK>(string arg0, K arg1, StreamPartitioner<K, object> arg2)

Parameters

arg0 string

String

arg1 K

K

arg2 StreamPartitioner<K, object>

StreamPartitioner

Returns

KeyQueryMetadata

KeyQueryMetadata

Type Parameters

K
TJVMK

Query<R>(StateQueryRequest<R>)

public StateQueryResult<R> Query<R>(StateQueryRequest<R> arg0)

Parameters

arg0 StateQueryRequest<R>

StateQueryRequest

Returns

StateQueryResult<R>

StateQueryResult

Type Parameters

R

RemoveStreamThread()

public Optional<String> RemoveStreamThread()

Returns

Optional<String>

Optional

RemoveStreamThread(TimeSpan)

public String RemoveStreamThread(TimeSpan arg0)

Parameters

arg0 TimeSpan

Duration

Returns

String

Optional

Resume()

public void Resume()

SetGlobalStateRestoreListener(StateRestoreListener)

public void SetGlobalStateRestoreListener(StateRestoreListener arg0)

Parameters

arg0 StateRestoreListener

StateRestoreListener

SetStandbyUpdateListener(StandbyUpdateListener)

public void SetStandbyUpdateListener(StandbyUpdateListener arg0)

Parameters

arg0 StandbyUpdateListener

StandbyUpdateListener

SetStateListener(StateListener)

public void SetStateListener(KafkaStreams.StateListener arg0)

Parameters

arg0 KafkaStreams.StateListener

KafkaStreams.StateListener

SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)

public void SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler arg0)

Parameters

arg0 StreamsUncaughtExceptionHandler

StreamsUncaughtExceptionHandler

Start()

public void Start()

Exceptions

IllegalStateException
StreamsException

Store<TKNetManagedStore, TStore>(StoreQueryParameters<TStore>)

public TKNetManagedStore Store<TKNetManagedStore, TStore>(StoreQueryParameters<TStore> arg0) where TKNetManagedStore : ManagedStore<TStore>, IGenericSerDesFactoryApplier, new()

Parameters

arg0 StoreQueryParameters<TStore>

StoreQueryParameters

Returns

TKNetManagedStore

T

Type Parameters

TKNetManagedStore
TStore

Store<TKNetManagedStore, TStore>(string, StoreType<TKNetManagedStore, TStore>)

public TKNetManagedStore Store<TKNetManagedStore, TStore>(string storageId, QueryableStoreTypes.StoreType<TKNetManagedStore, TStore> storeType) where TKNetManagedStore : ManagedStore<TStore>, IGenericSerDesFactoryApplier, new()

Parameters

storageId string
storeType QueryableStoreTypes.StoreType<TKNetManagedStore, TStore>

Returns

TKNetManagedStore

T

Type Parameters

TKNetManagedStore
TStore

StreamsMetadataForStore(string)

public Collection<StreamsMetadata> StreamsMetadataForStore(string arg0)

Parameters

arg0 string

String

Returns

Collection<StreamsMetadata>

Collection

Operators

implicit operator KafkaStreams(KNetStreams)

Converter from KNetStreams to KafkaStreams

public static implicit operator KafkaStreams(KNetStreams t)

Parameters

t KNetStreams

Returns

KafkaStreams