Re: [VOTE] 2.3.1 RC2

2019-10-21 Thread Jonathan Gordon
It appears issue 8950 is merged and in the rc2 release but I'm not seeing it in the release notes: https://issues.apache.org/jira/browse/KAFKA-8950 Would be great to get confirmation that it will be included and would be awesome to see it in the release notes. Thanks! Jonathan On Fri, Oct 18,

Re: Kafka Streams Session store performance degradation from 0.10.2.1 to 0.11.0.3

2018-11-08 Thread Jonathan Gordon
e that we added a new operator `suppress()` in upcoming 2.1> > release, that allows you to do rate control without caching:> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-328%3A+Ability+to+suppress+updates+for+KTables> > > Hope this helps.> > > > -Matthias>

Kafka Streams Session store performance degradation from 0.10.2.1 to 0.11.0.3

2018-11-06 Thread Jonathan Gordon
I have a Kafka Streams app that I'm trying to upgrade from 0.10.2.1 to 0.11.0.3 but when I do I notice that CPU goes way up and consumption goes down. A thread profile indicates that the most expensive task is during our aggregation, fetching from the cache. Thread profile with caching: