Namespace Org.Apache.Kafka.Streams.Processor
Classes
- BatchingStateRestoreCallbackDirect
Direct override of BatchingStateRestoreCallback or its generic type if there is one
- PunctuatorDirect
Direct override of Punctuator or its generic type if there is one
- StandbyUpdateListenerDirect
Direct override of StandbyUpdateListener or its generic type if there is one
- StateRestoreCallback
Listener for Kafka StateRestoreCallback. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IStateRestoreCallback
- StateRestoreCallbackDirect
Direct override of StateRestoreCallback or its generic type if there is one
- StateRestoreListener
Listener for Kafka StateRestoreListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IStateRestoreListener
- StateRestoreListenerDirect
Direct override of StateRestoreListener or its generic type if there is one
- StreamPartitionerDirect
Direct override of StreamPartitioner or its generic type if there is one
- StreamPartitionerDirect<K, V>
Direct override of StreamPartitioner or its generic type if there is one
- StreamPartitioner<K, V>
Listener for Kafka StreamPartitioner. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IStreamPartitioner<K, V>
- TimestampExtractor
Listener for Kafka TimestampExtractor. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements ITimestampExtractor
- TimestampExtractorDirect
Direct override of TimestampExtractor or its generic type if there is one
- TopicNameExtractorDirect
Direct override of TopicNameExtractor or its generic type if there is one
- TopicNameExtractorDirect<K, V>
Direct override of TopicNameExtractor or its generic type if there is one
- TopicNameExtractor<K, V>
Listener for Kafka TopicNameExtractor. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements ITopicNameExtractor<K, V>
Interfaces
- IBatchingStateRestoreCallback
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.processor.BatchingStateRestoreCallback implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.html
- ICancellable
.NET interface for TO BE DEFINED FROM USER
- ICommitCallback
.NET interface for TO BE DEFINED FROM USER
- IConnectedStoreProvider
.NET interface for TO BE DEFINED FROM USER
- IProcessorContext
.NET interface for TO BE DEFINED FROM USER
- IPunctuator
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.processor.Punctuator implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/Punctuator.html
- IRecordContext
.NET interface for TO BE DEFINED FROM USER
- IStandbyUpdateListener
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.processor.StandbyUpdateListener implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html
- IStateRestoreCallback
Listener for Kafka StateRestoreCallback. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IStateRestoreListener
Listener for Kafka StateRestoreListener. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IStateStore
.NET interface for TO BE DEFINED FROM USER
- IStateStoreContext
.NET interface for TO BE DEFINED FROM USER
- IStreamPartitioner<K, V>
Listener for Kafka StreamPartitioner. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- ITimestampExtractor
Listener for Kafka TimestampExtractor. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- ITopicNameExtractor
Listener for Kafka TopicNameExtractor. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- ITopicNameExtractor<K, V>
Listener for Kafka TopicNameExtractor. Extends ITopicNameExtractor