Table of Contents

Namespace Org.Apache.Kafka.Clients.Consumer

Classes

AcknowledgeType

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/AcknowledgeType.html

AcknowledgementCommitCallback

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/AcknowledgementCommitCallback.html

CloseOptions

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/CloseOptions.html

CloseOptions.GroupMembershipOperation

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/CloseOptions.GroupMembershipOperation.html

CommitFailedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/CommitFailedException.html

Consumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/Consumer.html

ConsumerConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerConfig.html

ConsumerGroupMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerGroupMetadata.html

ConsumerInterceptor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerInterceptor.html

ConsumerInterceptorDirect

Concrete CLR representation of ConsumerInterceptor returned by the JVM.

ConsumerInterceptorDirect<K, V>

Concrete CLR representation of ConsumerInterceptor returned by the JVM.

ConsumerInterceptor<K, V>

Listener for Kafka ConsumerRebalanceListener. Extends JVMBridgeListener, implements IConsumerInterceptor<K, V>

ConsumerPartitionAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.html

ConsumerPartitionAssignor.Assignment

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.Assignment.html

ConsumerPartitionAssignor.GroupAssignment

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.GroupAssignment.html

ConsumerPartitionAssignor.GroupSubscription

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.GroupSubscription.html

ConsumerPartitionAssignor.RebalanceProtocol

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.RebalanceProtocol.html

ConsumerPartitionAssignor.Subscription

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.Subscription.html

ConsumerPartitionAssignorDirect

Concrete CLR representation of ConsumerPartitionAssignor returned by the JVM.

ConsumerRebalanceListener

Listener for Kafka ConsumerRebalanceListener. Extends JVMBridgeListener, implements IConsumerRebalanceListener

ConsumerRebalanceListenerDirect

Concrete CLR representation of ConsumerRebalanceListener returned by the JVM.

ConsumerRecord

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecord.html

ConsumerRecord<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecord.html

ConsumerRecords

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecords.html

ConsumerRecords<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ConsumerRecords.html

Consumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/Consumer.html

CooperativeStickyAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/CooperativeStickyAssignor.html

GroupProtocol

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/GroupProtocol.html

InvalidOffsetException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/InvalidOffsetException.html

KafkaConsumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaConsumer.html

KafkaConsumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaConsumer.html

KafkaShareConsumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html

KafkaShareConsumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/KafkaShareConsumer.html

LogTruncationException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/LogTruncationException.html

MockConsumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockConsumer.html

MockConsumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockConsumer.html

MockShareConsumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.html

MockShareConsumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/MockShareConsumer.html

NoOffsetForPartitionException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.html

OffsetAndMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/OffsetAndMetadata.html

OffsetAndTimestamp

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/OffsetAndTimestamp.html

OffsetCommitCallback

Listener for Kafka OffsetCommitCallback. Extends JVMBridgeListener, implements IOffsetCommitCallback

OffsetCommitCallbackDirect

Concrete CLR representation of OffsetCommitCallback returned by the JVM.

OffsetOutOfRangeException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html

OffsetResetStrategy

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/OffsetResetStrategy.html

RangeAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/RangeAssignor.html

RetriableCommitFailedException

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/RetriableCommitFailedException.html

RoundRobinAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/RoundRobinAssignor.html

ShareConsumer

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ShareConsumer.html

ShareConsumer<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ShareConsumer.html

StickyAssignor

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/StickyAssignor.html

SubscriptionPattern

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/SubscriptionPattern.html

Interfaces

IAcknowledgementCommitCallback

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/AcknowledgementCommitCallback.html

IConsumer

.NET interface for Consumer

IConsumerInterceptor<K, V>

Listener for Kafka ConsumerInterceptor. Extends 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/4.2.1/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.html

IConsumerRebalanceListener

Listener for Kafka ConsumerRebalanceListener. Extends IJVMBridgeBase

IConsumer<K, V>

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/Consumer.html

IOffsetCommitCallback

Listener for Kafka OffsetCommitCallback. Extends IJVMBridgeBase

IShareConsumer<K, V>

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.2.1/org/apache/kafka/clients/consumer/ShareConsumer.html