Package org.apache.kafka.streams.processor.assignment

Interface TaskTopicPartition

public interface TaskTopicPartition
This is a simple container class used during the assignment process to distinguish TopicPartitions type. Since the assignment logic can depend on the type of topic we're looking at, and the rack information of the partition, this container class should have everything necessary to make informed task assignment decisions.

  • Method Details Link icon

    • topicPartition Link icon

      TopicPartition topicPartition()
      Returns:
      the TopicPartition for this task.

    • isSource Link icon

      boolean isSource()
      Returns:
      whether the underlying topic is a source topic or not. Source changelog topics are both source topics and changelog topics.

    • isChangelog Link icon

      boolean isChangelog()
      Returns:
      whether the underlying topic is a changelog topic or not. Source changelog topics are both source topics and changelog topics.

    • rackIds Link icon

      Optional<Set<String>> rackIds()
      Returns:
      the broker rack ids on which this topic partition resides. If no information could be found, this will return an empty optional value.