You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/11/13 17:32:00 UTC

[jira] [Commented] (KAFKA-7622) Add findSessions functionality to ReadOnlySessionStore

    [ https://issues.apache.org/jira/browse/KAFKA-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16685508#comment-16685508 ] 

Bill Bejeck commented on KAFKA-7622:
------------------------------------

Hi [~xmar], this seems like a useful feature. 

Please note that since the proposal involves changing a public interface a KIP ([https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals)] is required first. 

If you'd like to do the KIP yourself and would like some help with it, don't hesitate to ask on the dev mailing list, or you can ask here initially as well.

Thanks,

Bill

> Add findSessions functionality to ReadOnlySessionStore
> ------------------------------------------------------
>
>                 Key: KAFKA-7622
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7622
>             Project: Kafka
>          Issue Type: New Feature
>          Components: streams
>            Reporter: Di Campo
>            Priority: Major
>              Labels: needs-kip
>
> When creating a session store from the DSL, and you get a {{ReadOnlySessionStore}}, you can fetch by key, but not by key and time as in a {{SessionStore}}, even if the key type is a {{Windowed<K>}}. So you would have to iterate through it to find the time-related entries, which should be less efficient than querying by time.
> So the purpose of this ticket is to be able to query the store with (key, time).
> Proposal is to add {{SessionStore's findSessions}}-like methods (i.e. time-bound access) to {{ReadOnlySessionStore.}}
>   



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)