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
All Methods Instance Methods Concrete Methods 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()
-
-
-
Constructor Detail
-
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)
-
-
Method Detail
-
userData
public ByteBuffer userData()
-
ownedPartitions
public List<TopicPartition> ownedPartitions()
-
-