[KAFKA-9429] Allow ability to control whether stale reads out of state stores are desirable

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.5.0
• Component/s: streams
• Assignee: Vinoth Chandar
• Reporter: Vinoth Chandar
• Created: 14/Jan/20 17:35
• Updated: 16/Jan/20 22:44
• Resolved: 16/Jan/20 22:44

Description

From John :

 

I also meant to talk with you about the change to allow querying recovering stores. I think you might have already talked with Matthias a little about this in the scope of KIP-216, but it's probably not ok to just change the default from only allowing query while running, since there are actually people depending on full-consistency queries for correctness right now.

 

What we can do is add an overload KafkaStreams.store(name, QueriableStoreType, QueriableStoreOptions), with one option: queryStaleState(true/false) (your preference on the name, I just made that up right now). The default would be false, and KSQL would set it to true. While false, it would not allow querying recovering stores OR standbys. This basically allows a single switch to preserve existing behavior.

 

 

Issue Links

• links to: Github PR #7962