[ 
https://issues.apache.org/jira/browse/KAFKA-6663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400914#comment-16400914
 ] 

Matthias J. Sax commented on KAFKA-6663:
----------------------------------------

You are right. It should be `all` partitions.

> 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
>            Reporter: huxihx
>            Priority: Minor
>              Labels: documentation
>
> 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)

Reply via email to