Package org.apache.kafka.clients.consumer

Class ConsumerPartitionAssignor.Subscription

java.lang.Object

org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Subscription

Enclosing interface:

ConsumerPartitionAssignor

public static final class ConsumerPartitionAssignor.Subscription
extends Object

Constructor Summary

Constructors

Constructor	Description
Subscription(List<String> topics)
Subscription(List<String> topics, ByteBuffer userData)
Subscription(List<String> topics, ByteBuffer userData, List<TopicPartition> ownedPartitions)
Subscription(List<String> topics, ByteBuffer userData, List<TopicPartition> ownedPartitions, int generationId, Optional<String> rackId)

Method Summary

Modifier and Type	Method	Description
Optional<Integer>	generationId()
Optional<String>	groupInstanceId()
List<TopicPartition>	ownedPartitions()
Optional<String>	rackId()
void	setGroupInstanceId(Optional<String> groupInstanceId)
List<String>	topics()
String	toString()
ByteBuffer	userData()

Methods inherited from class java.lang.Object

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

Constructor Details

Subscription

public Subscription(List<String> topics,
 ByteBuffer userData,
 List<TopicPartition> ownedPartitions,
 int generationId,
 Optional<String> rackId)

Subscription

public Subscription(List<String> topics,
 ByteBuffer userData,
 List<TopicPartition> ownedPartitions)

Subscription

public Subscription(List<String> topics,
 ByteBuffer userData)

Subscription

public Subscription(List<String> topics)

Method Details

topics

public List<String> topics()

userData

public ByteBuffer userData()

ownedPartitions

public List<TopicPartition> ownedPartitions()

rackId

public Optional<String> rackId()

setGroupInstanceId

public void setGroupInstanceId(Optional<String> groupInstanceId)

groupInstanceId

public Optional<String> groupInstanceId()

generationId

public Optional<Integer> generationId()

toString

public String toString()

Overrides:

toString in class Object