[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16295558#comment-16295558 ]
Richard Yu commented on KAFKA-6328: ----------------------------------- Sorry, I am currently operating on "one active PR" basis. Meaning I am operating directly on my clone of Kafka mirror. I will work towards getting out more active PRs in the future and improving my system for commits. > 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 > Affects Versions: 1.0.0 > Reporter: Guozhang Wang > Labels: newbie > Attachments: kafka-6328.diff > > > 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)