[ https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax resolved KAFKA-6663. ------------------------------------ Resolution: Fixed > Expression for GlobalKTable is not correct > ------------------------------------------ > > Key: KAFKA-6663 > URL: https://issues.apache.org/jira/browse/KAFKA-6663 > Project: Kafka > Issue Type: Bug > Components: documentation, streams > Affects Versions: 1.1.0, 1.0.1 > Reporter: huxihx > Assignee: huxihx > Priority: Minor > Labels: documentation > Fix For: 1.1.0, 1.0.1 > > > In [this stream doc > section|https://kafka.apache.org/11/documentation/streams/developer-guide/dsl-api#creating-source-streams-from-kafka], > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)