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)

Reply via email to