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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.0/org/apache/kafka/clients/consumer/Consumer.html#commitSync--

void CommitSync()

CommitSync(Duration)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.0/org/apache/kafka/clients/consumer/Consumer.html#enforceRebalance--

void EnforceRebalance()

EnforceRebalance(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-clients/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.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/3.9.0/org/apache/kafka/clients/consumer/Consumer.html#unsubscribe--

void Unsubscribe()

Wakeup()

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

void Wakeup()