[jira] [Created] (KAFKA-14123) Delete with null value not supported in Streams PersistantWindowsStore

["Pawan Sharma (Jira)" <ji...@apache.org>]

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)