Pawan Sharma created KAFKA-14123:
------------------------------------
Summary: Delete with null value not supported in Streams
PersistantWindowsStore
Key: KAFKA-14123
URL: https://issues.apache.org/jira/browse/KAFKA-14123
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 3.0.0
Reporter: Pawan Sharma
Unable to delete an Window entry from Persistant Windows Store by passing null
value in the body.
Put in this class does not check if the value is null and invoke the remove
method.
[https://github.com/apache/kafka/blob/3.0.0/streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java]
Where as the same feature is working in InMemoryWindowsStore, where the null
values are treated as delete. line no 126.
[https://github.com/apache/kafka/blob/3.0.0/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java]
This behaviour is little in contrast to all other stores including kv stores,
where a null value is treated as delete and also complys with the behaviour of
compressed Kafka topic.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
