kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jonathan Gordon <jonathangor...@newrelic.com.INVALID>
Subject Kafka Streams Session store performance degradation from to
Date Tue, 06 Nov 2018 17:49:19 GMT
I have a Kafka Streams app that I'm trying to upgrade from to 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:

If I disable the cache both performance and consumption are good but we are
producing every single aggregation modification, which is not what we want.

Thread profile without caching:

I read this thread, which seems relevant e


Notably: "Note, that caching was _not_ introduced to reduce the writes to
RocksDB, but to reduce the write the the changelog topic and to reduce the
number of records send downstream."

So how can we reduce the number of records sent downstream while
maintaining the same performance characteristics that we have with caching
turned off? Or put another way, how can I upgrade my app without taking a
hit in performance or behavior?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message