Interface IConsumer<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Consumer

Assembly

MASES.KNet.dll

KNet extension of IConsumer<K, V>

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

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inherited Members

IConsumer<TJVMK, TJVMV>.Poll(Duration)

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)

Properties

IsCompleting

true if the IConsumer<K, V, TJVMK, TJVMV> instance is completing async operation

bool IsCompleting { get; }

Property Value

bool

IsEmpty

true if the IConsumer<K, V, TJVMK, TJVMV> instance has an empty set of items in async operation

bool IsEmpty { get; }

Property Value

bool

WaitingMessages

Number of messages in the IConsumer<K, V, TJVMK, TJVMV> instance waiting to be processed in async operation

int WaitingMessages { get; }

Property Value

int

Methods

Consume(long, Action<ConsumerRecord<K, V, TJVMK, TJVMV>>)

KNet sync extension for Poll(Duration)

void Consume(long timeoutMs, Action<ConsumerRecord<K, V, TJVMK, TJVMV>> callback)

Parameters

timeoutMs long

Timeout in milliseconds

callback Action<ConsumerRecord<K, V, TJVMK, TJVMV>>

The Action<T> where receives ConsumerRecord<K, V, TJVMK, TJVMV>

ConsumeAsync(long)

KNet async extension for Poll(Duration)

bool ConsumeAsync(long timeoutMs)

Parameters

timeoutMs long

Timeout in milliseconds

Returns

bool

true if something was enqued for Async operations

Poll(long)

KNet extension for Poll(Duration)

ConsumerRecords<K, V, TJVMK, TJVMV> Poll(long timeoutMs)

Parameters

timeoutMs long

Timeout in milliseconds

Returns

ConsumerRecords<K, V, TJVMK, TJVMV>

ConsumerRecords<K, V, TJVMK, TJVMV>

Poll(TimeSpan)

KNet extension for Poll(Duration)

ConsumerRecords<K, V, TJVMK, TJVMV> Poll(TimeSpan timeout)

Parameters

timeout TimeSpan

Timeout expressed as TimeSpan

Returns

ConsumerRecords<K, V, TJVMK, TJVMV>

ConsumerRecords<K, V, TJVMK, TJVMV>

SetCallback(Action<ConsumerRecord<K, V, TJVMK, TJVMV>>)

Sets the Action<T> to use to receive ConsumerRecord<K, V, TJVMK, TJVMV>

void SetCallback(Action<ConsumerRecord<K, V, TJVMK, TJVMV>> cb)

Parameters

cb Action<ConsumerRecord<K, V, TJVMK, TJVMV>>

The callback Action<T>