I updated my consumer to that build. The memory issue seems to have abated.
TY!
Have started seeing this exception semi-regularly though:
ERROR o.a.k.c.c.i.ConsumerCoordinator - User provided listener
org.apache.kafka.streams.processor.internals.StreamThread$1 for group
MinuteAgg failed on parti
Perhaps that's the problem. Yes - I'm still using 0.10.1.0.
Does this involve a broker update?
On Fri, Dec 9, 2016 at 7:12 AM, Damian Guy wrote:
> Hi Jon,
>
> Are you using 0.10.1? There is a resource leak to do with the Window
> Iterator. The bug has been fixed on the 0.10.1 branch (which will
Hi Jon,
Are you using 0.10.1? There is a resource leak to do with the Window
Iterator. The bug has been fixed on the 0.10.1 branch (which will soon be
released as 0.10.1.1)
and it is also fixed in the confluent fork.
You can get the confluent version by using the following:
conflue
