[KAFKA-6826] Avoid range scans when forwarding values in window store aggregations

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Component/s: streams
• Assignee: Xavier Léauté
• Reporter: Xavier Léauté
• Created: 25/Apr/18 10:16
• Updated: 01/May/18 15:02
• Resolved: 01/May/18 15:02

Description

This is a follow-up to KAFKA-6560, where we missed at least one case that should be using single point queries instead of range-scans when forwarding values during aggregation.

Since a single range scan can sometimes account for 75% of aggregation cpu time, fixing this should provide some significant speedups (see attached flamegraph)

Issue Links

• links to: GitHub Pull Request #4927