Class TaskId

java.lang.Object
org.apache.kafka.streams.processor.TaskId
All Implemented Interfaces:
Comparable<TaskId>

public class TaskId extends Object implements Comparable<TaskId>
The task ID representation composed as subtopology (aka topicGroupId) plus the assigned partition ID.
  • Field Details

    • NAMED_TOPOLOGY_DELIMITER

      public static final String NAMED_TOPOLOGY_DELIMITER
      See Also:
    • topicGroupId

      @Deprecated public final int topicGroupId
      Deprecated.
      The ID of the subtopology, aka topicGroupId.
    • partition

      @Deprecated public final int partition
      Deprecated.
      The ID of the partition.
  • Constructor Details

    • TaskId

      public TaskId(int topicGroupId, int partition)
    • TaskId

      public TaskId(int topicGroupId, int partition, String topologyName)
  • Method Details