Re: Facing memory issues with kafka streams application

2019-09-11 Thread Prakash Y
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

Re: Facing memory issues with kafka streams application

2019-09-11 Thread Prakash Y
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

`Facing memory issues with Kafka streams application

2019-09-11 Thread Prakash Y
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

Facing memory issues with Kafka streams application

2019-09-11 Thread Prakash Y
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