[
https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-8159:
---------------------------------------
Description:
If a user creates a queryable state store using one of the signed built-in
serdes (eg Integer) for the key, there is nothing preventing records with
negative keys from being inserted and/or fetched individually. However if the
user tries to query the store for a range of keys starting with a negative
number, unexpected behavior results that is store-specific.
For RocksDB stores with caching disabled, an empty iterator will be returned.
For in-memory stores and ANY store with caching enabled, Streams will throw an
unchecked exception.
This situation should be handled more gracefully, or users should be informed
of this limitation and the result should at least be consist across types of
store.
was:
If a user creates a queryable state store using one of the signed built-in
serdes (eg Integer) for the key, there is nothing preventing records with
negative keys from being inserted and/or fetched individually. However if the
user tries to query the store for a range of keys starting with a negative
number, unexpected behavior results that is store-specific.
For RocksDB stores with caching disabled, Streams will silently miss the
negative keys and return those from the range [0, keyTo].
For in-memory stores and ANY store with caching enabled, Streams will throw an
unchecked exception and crash.
This situation should be handled more gracefully, or users should be informed
of this limitation and the result should at least be consist across types of
store.
> Multi-key range queries with negative keyFrom results in unexpected behavior
> ----------------------------------------------------------------------------
>
> Key: KAFKA-8159
> URL: https://issues.apache.org/jira/browse/KAFKA-8159
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: Sophie Blee-Goldman
> Priority: Major
>
> If a user creates a queryable state store using one of the signed built-in
> serdes (eg Integer) for the key, there is nothing preventing records with
> negative keys from being inserted and/or fetched individually. However if the
> user tries to query the store for a range of keys starting with a negative
> number, unexpected behavior results that is store-specific.
>
> For RocksDB stores with caching disabled, an empty iterator will be returned.
> For in-memory stores and ANY store with caching enabled, Streams will throw
> an unchecked exception.
>
> This situation should be handled more gracefully, or users should be informed
> of this limitation and the result should at least be consist across types of
> store.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
