Damian Guy created KAFKA-5054: --------------------------------- Summary: ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized Key: KAFKA-5054 URL: https://issues.apache.org/jira/browse/KAFKA-5054 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.2.0 Reporter: Damian Guy Fix For: 0.11.0.0
{{putIfAbsent}} and {{delete}} should be synchronized as they involve at least 2 operations on the underlying store and may result in inconsistent results if someone were to query via IQ -- This message was sent by Atlassian JIRA (v6.3.15#6346)