Class ConsumerPartitionAssignor.Assignment

java.lang.Object
org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.Assignment
Enclosing interface:
ConsumerPartitionAssignor
public static final class ConsumerPartitionAssignor.Assignment extends Object
Represents the partition assignment for a consumer.

  • Constructor Details

    • Assignment

      public Assignment(List<TopicPartition> partitions, ByteBuffer userData)
      Constructs an assignment with partitions and user data.
      Parameters:
      partitions - The list of partitions assigned to the consumer
      userData - Nullable user data to include in the assignment

    • Assignment

      public Assignment(List<TopicPartition> partitions)
      Constructs an assignment with only partitions.
      Parameters:
      partitions - The list of partitions assigned to the consumer

  • Method Details

    • partitions

      public List<TopicPartition> partitions()
      Returns the list of partitions assigned to the consumer.
      Returns:
      The list of partitions

    • userData

      public ByteBuffer userData()
      Returns the user data included in the assignment.
      Returns:
      The user data, or null if none was provided

    • toString

      public String toString()
      Overrides:
      toString in class Object