Guozhang Wang created KAFKA-6328: ------------------------------------ Summary: Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups Key: KAFKA-6328 URL: https://issues.apache.org/jira/browse/KAFKA-6328 Project: Kafka Issue Type: Bug Components: streams Reporter: Guozhang Wang
Today when we group processor nodes into groups (i.e. sub-topologies), we assign the sub-topology id for global tables' dummy groups as well. As a result, the subtopology ids (and hence task ids) are not consecutive anymore. This is quite confusing for users trouble shooting and debugging; in addition, the node group for global stores are not useful as well: we simply exclude it in all the caller functions of makeNodeGroups. It would be better to simply exclude the global store's node groups in this function so that the subtopology ids and task ids are consecutive. -- This message was sent by Atlassian JIRA (v6.4.14#64029)