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)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

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 Detail

topics

public List<String> topics()

userData

public ByteBuffer userData()

ownedPartitions

public List<TopicPartition> ownedPartitions()

setGroupInstanceId

public void setGroupInstanceId(Optional<String> groupInstanceId)

groupInstanceId

public Optional<String> groupInstanceId()