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

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

                Dates

                • Created:
                  Updated:
                  Resolved: