Using the following topology:
KStream<String,SumRecord> kStream =
kStreamBuilder.stream(stringSerde,transSerde,TOPIC);
KTable<Windowed<String>, SumRecordCollector> ktAgg =
kStream.groupByKey().aggregate(
SumRecordCollector::new,
new Aggregate(),
TimeWindows.of(20 * 60 * 1000).advanceBy(60 * 1000),
cSerde, "table_stream");
When looking at windows as follows:
ktAgg.toStream().foreach((postKey, postValue) -> {
LOGGER.debug("start: {} end: {}",
postkey.window().start(), postkey.window().end());
}
The 'start' values are coming through properly incremented but the 'end'
values are all 9223372036854775807.
Is there something wrong with my topology? Some other bug that would cause
this?