Namespace Org.Apache.Kafka.Clients.Consumer
Classes
- ConsumerInterceptorDirect
Direct override of ConsumerInterceptor or its generic type if there is one
- ConsumerInterceptorDirect<K, V>
Direct override of ConsumerInterceptor or its generic type if there is one
- ConsumerInterceptor<K, V>
Listener for Kafka ConsumerRebalanceListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IConsumerInterceptor<K, V>
- ConsumerPartitionAssignorDirect
Direct override of ConsumerPartitionAssignor or its generic type if there is one
- ConsumerRebalanceListener
Listener for Kafka ConsumerRebalanceListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IConsumerRebalanceListener
- ConsumerRebalanceListenerDirect
Direct override of ConsumerRebalanceListener or its generic type if there is one
- OffsetCommitCallback
Listener for Kafka OffsetCommitCallback. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IOffsetCommitCallback
- OffsetCommitCallbackDirect
Direct override of OffsetCommitCallback or its generic type if there is one
Interfaces
- IAcknowledgementCommitCallback
.NET interface for TO BE DEFINED FROM USER
- IConsumerInterceptor<K, V>
Listener for Kafka ConsumerInterceptor. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IConsumerPartitionAssignor
.NET interface for org.mases.knet.generated.org.apache.kafka.clients.consumer.ConsumerPartitionAssignor implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.0/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.html
- IConsumerRebalanceListener
Listener for Kafka ConsumerRebalanceListener. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IConsumer<K, V>
.NET interface for TO BE DEFINED FROM USER
- IOffsetCommitCallback
Listener for Kafka OffsetCommitCallback. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IShareConsumer<K, V>
.NET interface for TO BE DEFINED FROM USER