Interface IConsumer

Namespace

Org.Apache.Kafka.Clients.Consumer

Assembly

MASES.KNet.dll

.NET interface for Consumer

public interface IConsumer : IJVMBridgeBase, IJVMBridgeDefinition, IDisposable

Inherited Members

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()

Methods

Assign(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#assign(java.util.Collection)

void Assign(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Assignment()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#assignment()

Set<TopicPartition> Assignment()

Returns

Set<TopicPartition>

Set

BeginningOffsets(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#beginningOffsets(java.util.Collection)

Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Returns

Map<TopicPartition, Long>

Map

BeginningOffsets(Collection<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#beginningOffsets(java.util.Collection,java.time.Duration)

Map<TopicPartition, Long> BeginningOffsets(Collection<TopicPartition> partitions, Duration timeout)

Parameters

partitions Collection<TopicPartition>

timeout Duration

Returns

Map<TopicPartition, Long>

Map

ClientInstanceId(Duration)

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

Uuid ClientInstanceId(Duration arg0)

Parameters

arg0 Duration

Duration

Returns

Uuid

Uuid

CommitAsync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitAsync()

void CommitAsync()

CommitAsync(Map<TopicPartition, OffsetAndMetadata>, OffsetCommitCallback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitAsync(java.util.Map,org.apache.kafka.clients.consumer.OffsetCommitCallback)

void CommitAsync(Map<TopicPartition, OffsetAndMetadata> offsets, OffsetCommitCallback callback)

Parameters

offsets Map<TopicPartition, OffsetAndMetadata>

callback OffsetCommitCallback

CommitAsync(OffsetCommitCallback)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitAsync(org.apache.kafka.clients.consumer.OffsetCommitCallback)

void CommitAsync(OffsetCommitCallback callback)

Parameters

callback OffsetCommitCallback

CommitSync()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitSync()

void CommitSync()

CommitSync(Duration)

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

void CommitSync(Duration timeout)

Parameters

timeout Duration

CommitSync(Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map)

void CommitSync(Map<TopicPartition, OffsetAndMetadata> offsets)

Parameters

offsets Map<TopicPartition, OffsetAndMetadata>

CommitSync(Map<TopicPartition, OffsetAndMetadata>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#commitSync(java.util.Map,java.time.Duration)

void CommitSync(Map<TopicPartition, OffsetAndMetadata> offsets, Duration timeout)

Parameters

offsets Map<TopicPartition, OffsetAndMetadata>

timeout Duration

Committed(Set<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#committed(java.util.Set)

Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> partitions)

Parameters

partitions Set<TopicPartition>

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

Committed(Set<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#committed(java.util.Set,java.time.Duration)

Map<TopicPartition, OffsetAndMetadata> Committed(Set<TopicPartition> partitions, Duration timeout)

Parameters

partitions Set<TopicPartition>

timeout Duration

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

CurrentLag(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#currentLag(org.apache.kafka.common.TopicPartition)

OptionalLong CurrentLag(TopicPartition topicPartition)

Parameters

topicPartition TopicPartition

Returns

OptionalLong

OptionalLong

EndOffsets(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#endOffsets(java.util.Collection)

Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Returns

Map<TopicPartition, Long>

Map

EndOffsets(Collection<TopicPartition>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#endOffsets(java.util.Collection,java.time.Duration)

Map<TopicPartition, Long> EndOffsets(Collection<TopicPartition> partitions, Duration timeout)

Parameters

partitions Collection<TopicPartition>

timeout Duration

Returns

Map<TopicPartition, Long>

Map

EnforceRebalance()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#enforceRebalance()

void EnforceRebalance()

EnforceRebalance(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#enforceRebalance(java.lang.String)

void EnforceRebalance(String reason)

Parameters

reason String

GroupMetadata()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#groupMetadata()

ConsumerGroupMetadata GroupMetadata()

Returns

ConsumerGroupMetadata

ConsumerGroupMetadata

ListTopics()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#listTopics()

Map<String, List<PartitionInfo>> ListTopics()

Returns

Map<String, List<PartitionInfo>>

Map

ListTopics(Duration)

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

Map<String, List<PartitionInfo>> ListTopics(Duration timeout)

Parameters

timeout Duration

Returns

Map<String, List<PartitionInfo>>

Map

Metrics<T>()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#metrics()

Map<MetricName, T> Metrics<T>() where T : Metric

Returns

Map<MetricName, T>

Map

Type Parameters

T

OffsetsForTimes(Map<TopicPartition, Long>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#offsetsForTimes(java.util.Map)

Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> timestampsToSearch)

Parameters

timestampsToSearch Map<TopicPartition, Long>

Returns

Map<TopicPartition, OffsetAndTimestamp>

Map

OffsetsForTimes(Map<TopicPartition, Long>, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#offsetsForTimes(java.util.Map,java.time.Duration)

Map<TopicPartition, OffsetAndTimestamp> OffsetsForTimes(Map<TopicPartition, Long> timestampsToSearch, Duration timeout)

Parameters

timestampsToSearch Map<TopicPartition, Long>

timeout Duration

Returns

Map<TopicPartition, OffsetAndTimestamp>

Map

PartitionsFor(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#partitionsFor(java.lang.String)

List<PartitionInfo> PartitionsFor(String topic)

Parameters

topic String

Returns

List<PartitionInfo>

List

PartitionsFor(String, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#partitionsFor(java.lang.String,java.time.Duration)

List<PartitionInfo> PartitionsFor(String topic, Duration timeout)

Parameters

topic String

timeout Duration

Returns

List<PartitionInfo>

List

Pause(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#pause(java.util.Collection)

void Pause(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Paused()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#paused()

Set<TopicPartition> Paused()

Returns

Set<TopicPartition>

Set

Position(TopicPartition)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#position(org.apache.kafka.common.TopicPartition)

long Position(TopicPartition partition)

Parameters

partition TopicPartition

Returns

long

long

Position(TopicPartition, Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#position(org.apache.kafka.common.TopicPartition,java.time.Duration)

long Position(TopicPartition partition, Duration timeout)

Parameters

partition TopicPartition

timeout Duration

Returns

long

long

Resume(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#resume(java.util.Collection)

void Resume(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Seek(TopicPartition, OffsetAndMetadata)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#seek(org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata)

void Seek(TopicPartition partition, OffsetAndMetadata offsetAndMetadata)

Parameters

partition TopicPartition

offsetAndMetadata OffsetAndMetadata

Seek(TopicPartition, long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#seek(org.apache.kafka.common.TopicPartition,long)

void Seek(TopicPartition partition, long offset)

Parameters

partition TopicPartition

offset long

SeekToBeginning(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#seekToBeginning(java.util.Collection)

void SeekToBeginning(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

SeekToEnd(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#seekToEnd(java.util.Collection)

void SeekToEnd(Collection<TopicPartition> partitions)

Parameters

partitions Collection<TopicPartition>

Subscribe(Collection<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#subscribe(java.util.Collection)

void Subscribe(Collection<String> topics)

Parameters

topics Collection<String>

Subscribe(Collection<String>, ConsumerRebalanceListener)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#subscribe(java.util.Collection,org.apache.kafka.clients.consumer.ConsumerRebalanceListener)

void Subscribe(Collection<String> topics, ConsumerRebalanceListener listener)

Parameters

topics Collection<String>

listener ConsumerRebalanceListener

Subscribe(Pattern)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#subscribe(java.util.regex.Pattern)

void Subscribe(Pattern pattern)

Parameters

pattern Pattern

Subscribe(Pattern, ConsumerRebalanceListener)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#subscribe(java.util.regex.Pattern,org.apache.kafka.clients.consumer.ConsumerRebalanceListener)

void Subscribe(Pattern pattern, ConsumerRebalanceListener listener)

Parameters

pattern Pattern

listener ConsumerRebalanceListener

Subscription()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#subscription()

Set<String> Subscription()

Returns

Set<String>

Set

Unsubscribe()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#unsubscribe()

void Unsubscribe()

Wakeup()

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/4.1.0/org/apache/kafka/clients/consumer/Consumer.html#wakeup()

void Wakeup()