Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.0.1, 1.1.0
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
- links to