[ https://issues.apache.org/jira/browse/KAFKA-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Work on KAFKA-4283 started by Damian Guy. ----------------------------------------- > records deleted from CachingKeyValueStore still appear in range and all > queries > ------------------------------------------------------------------------------- > > Key: KAFKA-4283 > URL: https://issues.apache.org/jira/browse/KAFKA-4283 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.10.1.0 > Reporter: Damian Guy > Assignee: Damian Guy > Fix For: 0.10.1.1 > > > Records deleted from CachingKeyValueStore appear in range and all queries. > The deleted record is replaced with an LRUCacheEntry(null), so that when a > flush happens the deletion can be sent downstream and removed from the > underlying store. > As this is valid and needed, the iterator used when querying a cached store > needs to be aware of the entries where LRUCacheEntry.value == null and skip > over them -- This message was sent by Atlassian JIRA (v6.3.4#6332)