Table of Contents

Class OffsetsUtils

Namespace
Org.Apache.Kafka.Tools
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html

public class OffsetsUtils : JVMBridgeBase<OffsetsUtils>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
OffsetsUtils
Implements
Inherited Members

Constructors

OffsetsUtils()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

public OffsetsUtils()

OffsetsUtils(IJVMBridgeBaseInitializer)

Internal constructor: used internally from JCOBridge

[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public OffsetsUtils(IJVMBridgeBaseInitializer initializer)

Parameters

initializer IJVMBridgeBaseInitializer

OffsetsUtils(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

public OffsetsUtils(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

CheckAllTopicPartitionsValid(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#checkAllTopicPartitionsValid(java.util.Collection)

public void CheckAllTopicPartitionsValid(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

FilterNonExistentPartitions(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#filterNonExistentPartitions(java.util.Collection)

public List<TopicPartition> FilterNonExistentPartitions(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

List<TopicPartition>

List

FilterNoneLeaderPartitions(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#filterNoneLeaderPartitions(java.util.Collection)

public List<TopicPartition> FilterNoneLeaderPartitions(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

List<TopicPartition>

List

GetLogEndOffsets(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#getLogEndOffsets(java.util.Collection)

public Map<TopicPartition, OffsetsUtils.LogOffsetResult> GetLogEndOffsets(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetsUtils.LogOffsetResult>

Map

GetLogOffsets(Collection<TopicPartition>, OffsetSpec)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#getLogOffsets(java.util.Collection,org.apache.kafka.clients.admin.OffsetSpec)

public Map<TopicPartition, OffsetsUtils.LogOffsetResult> GetLogOffsets(Collection<TopicPartition> arg0, OffsetSpec arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 OffsetSpec

OffsetSpec

Returns

Map<TopicPartition, OffsetsUtils.LogOffsetResult>

Map

ParseTopicPartitionsToReset(List<String>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#parseTopicPartitionsToReset(java.util.List)

public List<TopicPartition> ParseTopicPartitionsToReset(List<String> arg0)

Parameters

arg0 List<String>

List

Returns

List<TopicPartition>

List

Exceptions

ExecutionException
InterruptedException

ParseTopicsWithPartitions(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#parseTopicsWithPartitions(java.lang.String)

public Stream<TopicPartition> ParseTopicsWithPartitions(String arg0)

Parameters

arg0 String

String

Returns

Stream<TopicPartition>

Stream

PrintOffsetsToReset(Map<String, Map<TopicPartition, OffsetAndMetadata>>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#printOffsetsToReset(java.util.Map)

public static void PrintOffsetsToReset(Map<String, Map<TopicPartition, OffsetAndMetadata>> arg0)

Parameters

arg0 Map<String, Map<TopicPartition, OffsetAndMetadata>>

Map

ResetByDuration(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetByDuration(java.util.Collection)

public Map<TopicPartition, OffsetAndMetadata> ResetByDuration(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetByShiftBy(Collection<TopicPartition>, Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetByShiftBy(java.util.Collection,java.util.Map)

public Map<TopicPartition, OffsetAndMetadata> ResetByShiftBy(Collection<TopicPartition> arg0, Map<TopicPartition, OffsetAndMetadata> arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 Map<TopicPartition, OffsetAndMetadata>

Map

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetFromFile(String)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetFromFile(java.lang.String)

public Map<TopicPartition, OffsetAndMetadata> ResetFromFile(String arg0)

Parameters

arg0 String

String

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetPlanFromFile()

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetPlanFromFile()

public Optional<Map<String, Map<TopicPartition, OffsetAndMetadata>>> ResetPlanFromFile()

Returns

Optional<Map<String, Map<TopicPartition, OffsetAndMetadata>>>

Optional

ResetToCurrent(Collection<TopicPartition>, Map<TopicPartition, OffsetAndMetadata>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetToCurrent(java.util.Collection,java.util.Map)

public Map<TopicPartition, OffsetAndMetadata> ResetToCurrent(Collection<TopicPartition> arg0, Map<TopicPartition, OffsetAndMetadata> arg1)

Parameters

arg0 Collection<TopicPartition>

Collection

arg1 Map<TopicPartition, OffsetAndMetadata>

Map

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetToDateTime(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetToDateTime(java.util.Collection)

public Map<TopicPartition, OffsetAndMetadata> ResetToDateTime(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetToEarliest(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetToEarliest(java.util.Collection)

public Map<TopicPartition, OffsetAndMetadata> ResetToEarliest(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetToLatest(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetToLatest(java.util.Collection)

public Map<TopicPartition, OffsetAndMetadata> ResetToLatest(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

ResetToOffset(Collection<TopicPartition>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-tools/4.2.0/org/apache/kafka/tools/OffsetsUtils.html#resetToOffset(java.util.Collection)

public Map<TopicPartition, OffsetAndMetadata> ResetToOffset(Collection<TopicPartition> arg0)

Parameters

arg0 Collection<TopicPartition>

Collection

Returns

Map<TopicPartition, OffsetAndMetadata>

Map

Edit this page