We are allocating 1GB as like below,
KTable, OurObject> windowedStream = source
.suppress(Suppressed.untilWindowCloses(BufferConfig.maxBytes(<1GB>).shutDownWhenFull()));
and we are frequently getting below errors. Please help us in resolving this
issue.
Thanks,
Prakash.
Exception: java.lang.Ou
Hi Bill,
We are using hopping window and buffer size as 1GB as like in below code
KTable, OurObject> windowedMetricsTimeSeriesStream = source
.suppress(Suppressed.untilWindowCloses(BufferConfig.maxBytes(<1GB>).shutDownWhenFull()));
We are getting there exceptions very frequently, and stream proc
Hi,
I am using the hopping time window in Kafka streams with suppress option. I am
facing memory issues when the Kafka application is running continuously for 2
to 3 days of deployment without any restart on the machine.
We are using hopping window and buffer size as 1GB.
We are getting there
Hi,
I am using the hopping time window in Kafka streams with suppress option. I
am facing memory issues when the Kafka application is running continuously
for 2 to 3 days of deployment without any restart on the machine.
We are using hopping window and buffer size as 1GB.
We are getting there ex