Class KNetStreams
KNet extension of KafkaStreams
public class KNetStreams : IGenericSerDesFactoryApplier- Inheritance
-
KNetStreams
- Implements
- Inherited Members
Constructors
KNetStreams(Topology, StreamsConfigBuilder)
public KNetStreams(Topology arg0, StreamsConfigBuilder arg1)Parameters
arg0Topologyarg1StreamsConfigBuilder
KNetStreams(Topology, StreamsConfigBuilder, KNetClientSupplier)
public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, KNetClientSupplier arg2)Parameters
arg0Topologyarg1StreamsConfigBuilderarg2KNetClientSupplier
KNetStreams(Topology, StreamsConfigBuilder, KNetClientSupplier, Time)
public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, KNetClientSupplier arg2, Time arg3)Parameters
arg0Topologyarg1StreamsConfigBuilderarg2KNetClientSupplierarg3Time
KNetStreams(Topology, StreamsConfigBuilder, Time)
public KNetStreams(Topology arg0, StreamsConfigBuilder arg1, Time arg2)Parameters
arg0Topologyarg1StreamsConfigBuilderarg2Time
Properties
AllLocalStorePartitionLags
public Map<String, Map<Integer, LagInfo>> AllLocalStorePartitionLags { get; }Property Value
IsPaused
public bool IsPaused { get; }Property Value
MetadataForAllStreamsClients
public Collection<StreamsMetadata> MetadataForAllStreamsClients { get; }Property Value
MetadataForLocalThreads
public Set<ThreadMetadata> MetadataForLocalThreads { get; }Property Value
OverrideProperties
If set, this Func<T, TResult> will be called from PrepareProperties(StreamsConfigBuilder)
public static Func<StreamsConfigBuilder, Properties> OverrideProperties { get; set; }Property Value
State
public KafkaStreams.State State { get; }Property Value
Methods
AddStreamThread()
public Optional<String> AddStreamThread()Returns
CleanUp()
public void CleanUp()ClientInstanceIds(Duration)
public ClientInstanceIds ClientInstanceIds(Duration arg0)Parameters
Returns
Close()
public void Close()Close(Duration)
public bool Close(Duration arg0)Parameters
Returns
Exceptions
Close(CloseOptions)
public bool Close(KafkaStreams.CloseOptions arg0)Parameters
Returns
Exceptions
Close(TimeSpan)
public bool Close(TimeSpan arg0)Parameters
Returns
Exceptions
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 : MetricReturns
- Map<MetricName, ReturnExtendsOrg_Apache_Kafka_Common_Metric>
Type Parameters
ReturnExtendsOrg_Apache_Kafka_Common_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
builderStreamsConfigBuilderStreamsConfigBuilder 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
arg0stringarg1KKarg2ISerializer<K, byte[]>
Returns
Type Parameters
K
QueryMetadataForKey<K>(string, K, StreamPartitioner<K, object>)
public KeyQueryMetadata QueryMetadataForKey<K>(string arg0, K arg1, StreamPartitioner<K, object> arg2)Parameters
arg0stringarg1KKarg2StreamPartitioner<K, object>
Returns
Type Parameters
KThe key type
QueryMetadataForKey<K, TJVMK>(string, K, ISerializer<K, TJVMK>)
public KeyQueryMetadata QueryMetadataForKey<K, TJVMK>(string arg0, K arg1, ISerializer<K, TJVMK> arg2)Parameters
arg0stringarg1KKarg2ISerializer<K, TJVMK>
Returns
Type Parameters
KTJVMKThe JVM type of
K
QueryMetadataForKey<K, TJVMK>(string, K, StreamPartitioner<K, object>)
public KeyQueryMetadata QueryMetadataForKey<K, TJVMK>(string arg0, K arg1, StreamPartitioner<K, object> arg2)Parameters
arg0stringarg1KKarg2StreamPartitioner<K, object>
Returns
Type Parameters
KThe key type
TJVMKThe JVM type of
K
Query<R>(StateQueryRequest<R>)
public StateQueryResult<R> Query<R>(StateQueryRequest<R> arg0)Parameters
Returns
Type Parameters
R
RemoveStreamThread()
public Optional<String> RemoveStreamThread()Returns
RemoveStreamThread(TimeSpan)
KNet implementation of https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/KafkaStreams.html#removeStreamThread-java.time.Duration-
public String RemoveStreamThread(TimeSpan arg0)Parameters
Returns
Resume()
public void Resume()SetGlobalStateRestoreListener(StateRestoreListener)
public void SetGlobalStateRestoreListener(StateRestoreListener arg0)Parameters
SetStandbyUpdateListener(StandbyUpdateListener)
public void SetStandbyUpdateListener(StandbyUpdateListener arg0)Parameters
SetStateListener(StateListener)
public void SetStateListener(KafkaStreams.StateListener arg0)Parameters
SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)
public void SetUncaughtExceptionHandler(StreamsUncaughtExceptionHandler arg0)Parameters
Start()
public void Start()Exceptions
Store<TKNetManagedStore, TStore>(StoreQueryParameters<TStore>)
public TKNetManagedStore Store<TKNetManagedStore, TStore>(StoreQueryParameters<TStore> arg0) where TKNetManagedStore : ManagedStore<TStore>, IGenericSerDesFactoryApplier, new()Parameters
arg0StoreQueryParameters<TStore>
Returns
- TKNetManagedStore
TKNetManagedStore
Type Parameters
TKNetManagedStoreTStore
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
storageIdstringstoreTypeQueryableStoreTypes.StoreType<TKNetManagedStore, TStore>
Returns
- TKNetManagedStore
TKNetManagedStore
Type Parameters
TKNetManagedStoreTStore
StreamsMetadataForStore(string)
public Collection<StreamsMetadata> StreamsMetadataForStore(string arg0)Parameters
Returns
Operators
implicit operator KafkaStreams(KNetStreams)
Converter from KNetStreams to KafkaStreams
public static implicit operator KafkaStreams(KNetStreams t)