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 JVMBridgeListener, implements IStateRestoreCallback
- StateRestoreCallbackDirect
Direct override of StateRestoreCallback or its generic type if there is one
- StateRestoreListener
Listener for Kafka StateRestoreListener. Extends 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 JVMBridgeListener, implements IStreamPartitioner<K, V>
- TimestampExtractor
Listener for Kafka TimestampExtractor. Extends 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 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/4.0.0/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.html
- ICancellable
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/Cancellable.html
- ICommitCallback
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/CommitCallback.html
- IConnectedStoreProvider
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/ConnectedStoreProvider.html
- IProcessorContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/ProcessorContext.html
- 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/4.0.0/org/apache/kafka/streams/processor/Punctuator.html
- IRecordContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/RecordContext.html
- 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/4.0.0/org/apache/kafka/streams/processor/StandbyUpdateListener.html
- IStateRestoreCallback
Listener for Kafka StateRestoreCallback. Extends IJVMBridgeBase
- IStateRestoreListener
Listener for Kafka StateRestoreListener. Extends IJVMBridgeBase
- IStateStore
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/StateStore.html
- IStateStoreContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/StateStoreContext.html
- IStreamPartitioner<K, V>
Listener for Kafka StreamPartitioner. Extends IJVMBridgeBase
- ITimestampExtractor
Listener for Kafka TimestampExtractor. Extends IJVMBridgeBase
- ITopicNameExtractor
Listener for Kafka TopicNameExtractor. Extends IJVMBridgeBase
- ITopicNameExtractor<K, V>
Listener for Kafka TopicNameExtractor. Extends ITopicNameExtractor