You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "huxihx (JIRA)" <ji...@apache.org> on 2018/03/15 09:45:00 UTC
[jira] [Created] (KAFKA-6663) Expression for GlobalKTable is not
correct
huxihx created KAFKA-6663:
-----------------------------
Summary: 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
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)