[KAFKA-5216] Cached Session/Window store may return error on iterator.peekNextKey()

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.2.0, 0.11.0.0
• Fix Version/s: 0.11.0.0
• Component/s: streams
• Assignee: Xavier Léauté
• Reporter: Xavier Léauté
• Created: 10/May/17 23:55
• Updated: 12/May/17 22:28
• Resolved: 12/May/17 22:27

Description

AbstractMergedSortedCacheStoreIterator uses the wrong cache key deserializer in peekNextKey. This may result in errors or incorrect keys returned from peekNextKey on a WindowStoreIterator or SessionStoreIterator for a cached window or session store.

CachingKeyValueStore does not seem to be affected.

Issue Links

• links to: GitHub Pull Request #3016