Interface IConsumer<K, V>

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

.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

public interface IConsumer<K, V> : IConsumer, IJVMBridgeBase, IJVMBridgeDefinition, IDisposable, ICloseable, IAutoCloseable

Type Parameters

K

V

Inherited Members

IConsumer.Assignment()

IConsumer.Subscription()

IConsumer.Paused()

IConsumer.Metrics<T>()

IConsumer.Subscribe(Collection<String>)

IConsumer.Subscribe(Collection<String>, ConsumerRebalanceListener)

IConsumer.ClientInstanceId(Duration)

IConsumer.Assign(Collection<TopicPartition>)

IConsumer.Subscribe(Pattern, ConsumerRebalanceListener)

IConsumer.Subscribe(Pattern)

IConsumer.Unsubscribe()

IConsumer.CommitSync()

IConsumer.CommitSync(Duration)

IConsumer.CommitSync(Map<TopicPartition, OffsetAndMetadata>)

IConsumer.CommitSync(Map<TopicPartition, OffsetAndMetadata>, Duration)

IConsumer.CommitAsync()

IConsumer.CommitAsync(OffsetCommitCallback)

IConsumer.CommitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)

IConsumer.Seek(TopicPartition, long)

IConsumer.Seek(TopicPartition, OffsetAndMetadata)

IConsumer.SeekToBeginning(Collection<TopicPartition>)

IConsumer.SeekToEnd(Collection<TopicPartition>)

IConsumer.Position(TopicPartition)

IConsumer.Position(TopicPartition, Duration)

IConsumer.Committed(Set<TopicPartition>)

IConsumer.Committed(Set<TopicPartition>, Duration)

IConsumer.PartitionsFor(String)

IConsumer.PartitionsFor(String, Duration)

IConsumer.ListTopics()

IConsumer.ListTopics(Duration)

IConsumer.Pause(Collection<TopicPartition>)

IConsumer.Resume(Collection<TopicPartition>)

IConsumer.OffsetsForTimes(Map<TopicPartition, Long>)

IConsumer.OffsetsForTimes(Map<TopicPartition, Long>, Duration)

IConsumer.BeginningOffsets(Collection<TopicPartition>)

IConsumer.BeginningOffsets(Collection<TopicPartition>, Duration)

IConsumer.EndOffsets(Collection<TopicPartition>)

IConsumer.EndOffsets(Collection<TopicPartition>, Duration)

IConsumer.CurrentLag(TopicPartition)

IConsumer.GroupMetadata()

IConsumer.EnforceRebalance()

IConsumer.EnforceRebalance(String)

IConsumer.Wakeup()

IJVMBridgeBase.MonitorEnter()

IJVMBridgeBase.MonitorExit()

IJVMBridgeBase.IsInstanceOf(string)

IJVMBridgeBase.IsInstanceOf(IJavaType)

IJVMBridgeBase.IsInstanceOf<T>()

IJVMBridgeBase.RuntimeIsInstanceOf<T>()

IJVMBridgeBase.CastTo<TNewClass>()

IJVMBridgeBase.CastDirect<TNewClass>()

IJVMBridgeBase.DynBridgeInstance

IJVMBridgeBase.BridgeInstance

IJVMBridgeDefinition.BridgeClassName

IJVMBridgeDefinition.IsBridgeInterface

IJVMBridgeDefinition.IsBridgeAbstract

IJVMBridgeDefinition.IsBridgeStatic

IJVMBridgeDefinition.IsBridgeCloseable

IJVMBridgeDefinition.IsBridgeListener

IDisposable.Dispose()

ICloseable.Close()

Extension Methods

KafkaConsumerExtensions.ConsumeAsync<K, V>(IConsumer<K, V>)

KafkaConsumerExtensions.Consume<K, V>(IConsumer<K, V>, CancellationToken)

Methods

Poll(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.0.0/org/apache/kafka/clients/consumer/Consumer.html#poll(java.time.Duration)

ConsumerRecords<K, V> Poll(Duration timeout)

Parameters

timeout Duration

Returns

ConsumerRecords<K, V>

ConsumerRecords