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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Subscription(java.util.List<java.lang.String> topics)
Subscription(java.util.List<java.lang.String> topics, java.nio.ByteBuffer userData)
Subscription(java.util.List<java.lang.String> topics, java.nio.ByteBuffer userData, java.util.List<TopicPartition> ownedPartitions)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<java.lang.String>	groupInstanceId()
java.util.List<TopicPartition>	ownedPartitions()
void	setGroupInstanceId(java.util.Optional<java.lang.String> groupInstanceId)
java.util.List<java.lang.String>	topics()
java.nio.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(java.util.List<java.lang.String> topics,
                    java.nio.ByteBuffer userData,
                    java.util.List<TopicPartition> ownedPartitions)

Subscription

public Subscription(java.util.List<java.lang.String> topics,
                    java.nio.ByteBuffer userData)

Subscription

public Subscription(java.util.List<java.lang.String> topics)

Method Detail

topics

public java.util.List<java.lang.String> topics()

userData

public java.nio.ByteBuffer userData()

ownedPartitions

public java.util.List<TopicPartition> ownedPartitions()

setGroupInstanceId

public void setGroupInstanceId(java.util.Optional<java.lang.String> groupInstanceId)

groupInstanceId

public java.util.Optional<java.lang.String> groupInstanceId()