Package org.apache.storm.kafka.spout.subscription

# Class TopicAssigner

java.lang.Object
org.apache.storm.kafka.spout.subscription.TopicAssigner

All Implemented Interfaces:
  `Serializable`

public class TopicAssigner extends Object implements Serializable
Handles assigning partitions to the consumer and updating the rebalance listener.

See Also:
  - Serialized Form

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `TopicAssigner()`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `<K, V> boolean`
  `assignPartitions(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, Set<org.apache.kafka.common.TopicPartition> newAssignment, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener)`
  Assign partitions to the KafkaConsumer.

  ### Methods inherited from class java.lang.Object

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

- ## Constructor Details

  - ### TopicAssigner

    public TopicAssigner()

- ## Method Details

  - ### assignPartitions

    public <K, V> boolean assignPartitions(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, Set<org.apache.kafka.common.TopicPartition> newAssignment, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener)
    Assign partitions to the KafkaConsumer.
    Parameters:
      `consumer` - The Kafka consumer to assign partitions to
      `newAssignment` - The partitions to assign.
      `listener` - The rebalance listener to call back on when the assignment changes
    Returns:
      a boolean value indicating whether the partition assignment changed