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

Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 1.0.0
    • 1.1.0
    • streams

    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

            Yohan123 Richard Yu
            guozhang Guozhang Wang
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: