Package org.apache.kafka.clients.admin

Class ListConsumerGroupOffsetsOptions

java.lang.Object

org.apache.kafka.clients.admin.AbstractOptions<ListConsumerGroupOffsetsOptions>

org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions

@Evolving
public class ListConsumerGroupOffsetsOptions
extends AbstractOptions<ListConsumerGroupOffsetsOptions>

Options for Admin.listConsumerGroupOffsets(java.util.Map) and Admin.listConsumerGroupOffsets(String).

The API of this class is evolving, see Admin for details.

Constructor Summary

Constructors

Constructor	Description
ListConsumerGroupOffsetsOptions()

Method Summary

Modifier and Type	Method	Description
boolean	requireStable()
ListConsumerGroupOffsetsOptions	requireStable(boolean requireStable)	Sets an optional requireStable flag.
List<TopicPartition>	topicPartitions()	Deprecated. Since 3.3.
ListConsumerGroupOffsetsOptions	topicPartitions(List<TopicPartition> topicPartitions)	Deprecated. Since 3.3.

Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions

timeoutMs, timeoutMs

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ListConsumerGroupOffsetsOptions

public ListConsumerGroupOffsetsOptions()

Method Details

topicPartitions

@Deprecated
public ListConsumerGroupOffsetsOptions topicPartitions(List<TopicPartition> topicPartitions)

Deprecated.

Since 3.3. Use Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions) to specify topic partitions.

Set the topic partitions to list as part of the result. null includes all topic partitions.

Parameters:

topicPartitions - List of topic partitions to include

Returns:

This ListGroupOffsetsOptions

requireStable

public ListConsumerGroupOffsetsOptions requireStable(boolean requireStable)

Sets an optional requireStable flag.

topicPartitions

@Deprecated
public List<TopicPartition> topicPartitions()

Deprecated.

Since 3.3. Use Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions) to specify topic partitions.

Returns a list of topic partitions to add as part of the result.

requireStable

public boolean requireStable()