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

Expression for GlobalKTable is not correct

    XMLWordPrintableJSON

Details

    Description

      In this stream doc section, when reading records from Kafka to a global KTable, the doc says:
      `In the case of a GlobalKTable, the local GlobalKTable instance of every application instance will be populated with data from only a subset of the partitions of the input topic. Collectively, across all application instances, all input topic partitions are read and processed.`

      Is it correct? Each GlobalKTable instance only get assigned with a subset of the partitions of the input topic? I remember it should be able to consume all the partitions of the input topic.

      Attachments

        Issue Links

          Activity

            People

              huxi_2b huxihx
              huxi_2b huxihx
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: