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 a compounded key of (our key,
window key).
I am asking this because what is observed that when stream runs for few
days we start getting the exception where message size is greater than the
allowable message size.
However our messages are windowed on hourly windows, so size of a message
should be far less than the max message size.
Thanks
Sachin
