Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6328

Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.0.0
    • Fix Version/s: 1.1.0
    • Component/s: streams
    • Labels:

      Description

      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.

        Attachments

        1. kafka-6328.diff
          2 kB
          Richard Yu

          Activity

            People

            • Assignee:
              Yohan123 Richard Yu
              Reporter:
              guozhang Guozhang Wang
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: