You're welcome. Another one I found today https://docs.confluent.io/current/streams/developer-guide/dsl-api.html
> groupedStream.windowedBy(TimeUnit.MINUTES.toMillis(5)) should be > groupedStream.windowedBy(TimeWindows.of(TimeUnit.MINUTES.toMillis(5))) in two spots. On Mon, Dec 18, 2017 at 2:29 PM, Matthias J. Sax <matth...@confluent.io> wrote: > Thanks for reporting this! > > We will fix it. > > -Matthias > > On 12/17/17 7:05 PM, Philippe Derome wrote: > > I agree with Dmitry's first comment, it really looks like the paragraph > he > > points to under "Table" was pasted without edit from the one previously > > that pertained to "KStream". > > > > 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 > >> > > > >
