Also the javadoc here: https://github.com/apache/kafka/blob/e5daa40e316261e8e6cb8866ad9a4eedcf17f919/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java#L184-L185
Shouldn't it refer to the `Consumed`, given that it is provided in this overload? Sorry, I would post this to JIRA, but I couldn't find where. Maybe I don't have privileges. Dmitry On Sun, Dec 17, 2017 at 5:31 PM, Dmitry Minkovsky <dminkov...@gmail.com> wrote: > On https://docs.confluent.io/current/streams/developer-guide/dsl-api.html > for version 4.0.0: > > Under "Table", currently: > > > In the case of a KStream, the local KStream 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. > > Shouldn't it be KTable instead of KStream? > > Also, under "GlobalKTable", current: > > > 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. > > Shouldn't it say that all partitions are consumed by all instances of the > application? > > > Best, > Dmitry >
