Namespace Org.Apache.Kafka.Streams.Processor
Classes
- BatchingStateRestoreCallbackDirect
Concrete CLR representation of BatchingStateRestoreCallback returned by the JVM.
- PunctuatorDirect
Concrete CLR representation of Punctuator returned by the JVM.
- StandbyUpdateListenerDirect
Concrete CLR representation of StandbyUpdateListener returned by the JVM.
- StateRestoreCallback
Listener for Kafka StateRestoreCallback. Extends JVMBridgeListener, implements IStateRestoreCallback
- StateRestoreCallbackDirect
Concrete CLR representation of StateRestoreCallback returned by the JVM.
- StateRestoreListener
Listener for Kafka StateRestoreListener. Extends JVMBridgeListener, implements IStateRestoreListener
- StateRestoreListenerDirect
Concrete CLR representation of StateRestoreListener returned by the JVM.
- StreamPartitionerDirect
Concrete CLR representation of StreamPartitioner returned by the JVM.
- StreamPartitionerDirect<K, V>
Concrete CLR representation of StreamPartitioner returned by the JVM.
- StreamPartitioner<K, V>
Listener for Kafka StreamPartitioner. Extends JVMBridgeListener, implements IStreamPartitioner<K, V>
- TimestampExtractor
Listener for Kafka TimestampExtractor. Extends JVMBridgeListener, implements ITimestampExtractor
- TimestampExtractorDirect
Concrete CLR representation of TimestampExtractor returned by the JVM.
- TopicNameExtractorDirect
Concrete CLR representation of TopicNameExtractor returned by the JVM.
- TopicNameExtractorDirect<K, V>
Concrete CLR representation of TopicNameExtractor returned by the JVM.
- 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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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