ConsumerPartitionAssignor.Subscription (clients 8.1.0-ce API)

java.lang.Object

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

Enclosing interface:: ConsumerPartitionAssignor

public static final class ConsumerPartitionAssignor.Subscriptionextends 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