Namespace Org.Apache.Kafka.Clients.Consumer

Classes

AcknowledgeType

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

AcknowledgementCommitCallback

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

CommitFailedException

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

Consumer

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

ConsumerConfig

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

ConsumerGroupMetadata

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

ConsumerInterceptor

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

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 JVMBridgeListener, implements IConsumerInterceptor<K, V>

ConsumerPartitionAssignor

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

ConsumerPartitionAssignor.Assignment

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

ConsumerPartitionAssignor.GroupAssignment

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

ConsumerPartitionAssignor.GroupSubscription

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

ConsumerPartitionAssignor.RebalanceProtocol

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

ConsumerPartitionAssignor.Subscription

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

ConsumerPartitionAssignorDirect

Direct override of ConsumerPartitionAssignor or its generic type if there is one

ConsumerRebalanceListener

Listener for Kafka ConsumerRebalanceListener. Extends JVMBridgeListener, implements IConsumerRebalanceListener

ConsumerRebalanceListenerDirect

Direct override of ConsumerRebalanceListener or its generic type if there is one

ConsumerRecord

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

ConsumerRecord<K, V>

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

ConsumerRecords

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

ConsumerRecords<K, V>

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

Consumer<K, V>

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

CooperativeStickyAssignor

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

GroupProtocol

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

InvalidOffsetException

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

KafkaConsumer

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

KafkaConsumer<K, V>

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

KafkaShareConsumer

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

KafkaShareConsumer<K, V>

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

LogTruncationException

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

MockConsumer

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

MockConsumer<K, V>

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

MockShareConsumer

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

MockShareConsumer<K, V>

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

NoOffsetForPartitionException

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

OffsetAndMetadata

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

OffsetAndTimestamp

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

OffsetCommitCallback

Listener for Kafka OffsetCommitCallback. Extends JVMBridgeListener, implements IOffsetCommitCallback

OffsetCommitCallbackDirect

Direct override of OffsetCommitCallback or its generic type if there is one

OffsetOutOfRangeException

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

RangeAssignor

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

RetriableCommitFailedException

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

RoundRobinAssignor

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

ShareConsumer

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

ShareConsumer<K, V>

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

StickyAssignor

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

SubscriptionPattern

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/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.0.0/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.0.0/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.0.0/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.0.0/org/apache/kafka/clients/consumer/ShareConsumer.html