@InterfaceStability.Evolving public class ListConsumerGroupOffsetsOptions extends AbstractOptions<ListConsumerGroupOffsetsOptions>
Admin.listConsumerGroupOffsets(java.util.Map) and Admin.listConsumerGroupOffsets(String).
The API of this class is evolving, see Admin for details.
timeoutMs| Constructor and Description |
|---|
ListConsumerGroupOffsetsOptions() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
requireStable() |
ListConsumerGroupOffsetsOptions |
requireStable(boolean requireStable)
Sets an optional requireStable flag.
|
List<TopicPartition> |
topicPartitions()
Deprecated.
Since 3.3.
Use
Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)
to specify topic partitions. |
ListConsumerGroupOffsetsOptions |
topicPartitions(List<TopicPartition> topicPartitions)
Deprecated.
Since 3.3.
Use
Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)
to specify topic partitions. |
timeoutMs, timeoutMs@Deprecated public ListConsumerGroupOffsetsOptions topicPartitions(List<TopicPartition> topicPartitions)
Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)
to specify topic partitions.null includes all topic partitions.
topicPartitions - List of topic partitions to includepublic ListConsumerGroupOffsetsOptions requireStable(boolean requireStable)
@Deprecated public List<TopicPartition> topicPartitions()
Admin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)
to specify topic partitions.public boolean requireStable()