public static final class ConsumerPartitionAssignor.Subscription extends Object
Constructor and Description |
---|
Subscription(List<String> topics) |
Subscription(List<String> topics,
ByteBuffer userData) |
Subscription(List<String> topics,
ByteBuffer userData,
List<TopicPartition> ownedPartitions) |
Modifier and Type | Method and Description |
---|---|
Optional<String> |
groupInstanceId() |
List<TopicPartition> |
ownedPartitions() |
void |
setGroupInstanceId(Optional<String> groupInstanceId) |
List<String> |
topics() |
ByteBuffer |
userData() |
public Subscription(List<String> topics, ByteBuffer userData, List<TopicPartition> ownedPartitions)
public Subscription(List<String> topics, ByteBuffer userData)
public ByteBuffer userData()
public List<TopicPartition> ownedPartitions()