[KAFKA-6663] Expression for GlobalKTable is not correct

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.1, 1.1.0
• Fix Version/s: 1.0.1, 1.1.0
• Component/s: documentation, streams
• Labels: documentation
• Assignee: huxihx
• Reporter: huxihx
• Created: 15/Mar/18 09:44
• Updated: 16/Mar/18 20:31
• Resolved: 16/Mar/18 20:31

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.

Issue Links

• links to: GitHub Pull Request #4723