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.
-
Field Summary
Fields inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
requireStable
(boolean requireStable) Sets an optional requireStable flag.Deprecated.Since 3.3.topicPartitions
(List<TopicPartition> topicPartitions) Deprecated.Since 3.3.Methods inherited from class org.apache.kafka.clients.admin.AbstractOptions
timeoutMs, timeoutMs
-
Constructor Details
-
ListConsumerGroupOffsetsOptions
public ListConsumerGroupOffsetsOptions()
-
-
Method Details
-
topicPartitions
@Deprecated public ListConsumerGroupOffsetsOptions topicPartitions(List<TopicPartition> topicPartitions) Deprecated.Since 3.3. UseAdmin.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
Sets an optional requireStable flag. -
topicPartitions
Deprecated.Since 3.3. UseAdmin.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()
-