Page History

package org.apache.kafka.streams.processor;

/**
 * A wrapper class for basic task info
 */
public interface TaskInfo {
    /**
     * @return The ID of the subtopology that this task executes, ie the topicGroupId
     */
    int subtopologyId();

    /**
     * @return The ID number of the partition.
     */
    int partition();
}