org.apache.kafka.clients.admin

Class ListConsumerGroupOffsetsSpec

java.lang.Object

org.apache.kafka.clients.admin.ListConsumerGroupOffsetsSpec

@InterfaceStability.Evolving
public class ListConsumerGroupOffsetsSpec
extends Object

Specification of consumer group offsets to list using Admin.listConsumerGroupOffsets(java.util.Map). The API of this class is evolving, see Admin for details.

Constructor Summary

Constructors

Constructor and Description
ListConsumerGroupOffsetsSpec()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
Collection<TopicPartition>	topicPartitions() Returns the topic partitions whose offsets are to be listed for a consumer group.
ListConsumerGroupOffsetsSpec	topicPartitions(Collection<TopicPartition> topicPartitions) Set the topic partitions whose offsets are to be listed for a consumer group.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ListConsumerGroupOffsetsSpec

public ListConsumerGroupOffsetsSpec()

Method Detail

topicPartitions

public ListConsumerGroupOffsetsSpec topicPartitions(Collection<TopicPartition> topicPartitions)

Set the topic partitions whose offsets are to be listed for a consumer group. null includes all topic partitions.

Parameters:

topicPartitions - List of topic partitions to include

Returns:

This ListConsumerGroupOffsetSpec

topicPartitions

public Collection<TopicPartition> topicPartitions()

Returns the topic partitions whose offsets are to be listed for a consumer group. null indicates that offsets of all partitions of the group are to be listed.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object