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

Reply via email to