public int subtopology() {
        return topicGroupId;
    }
The namedTopology that this task belongs to, or null if it does not belong to one
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java