Re: what is the key used for change log topic backed by windowed store

Hi Sachin, The key is a combination of the record key + window start time + a sequence number. The timestamp is 8 bytes and the sequence number is 4 bytes. Thanks, Damian On Thu, 22 Dec 2016 at 15:26 Sachin Mittal wrote: > Hi All, > Our stream is something like > >

what is the key used for change log topic backed by windowed store

Hi All, Our stream is something like builder.stream() .groupByKey() .aggregate(Initializer, Aggregator, TimeWindows, valueSerde, "table-name') So This creates a changelog topic. I was wondering what would be the key used for this topic. Would it be they key we use to group by or