Apache Kafka, permission to contribute

Hi all, I would like to request permission to contribute to Apache Kafka. My wiki and jira id is "pstuedi". Thanks! -Patrick

[DISCUSS] KIP-763: Range queries with open endpoints

Hi everyone, I would like to start the discussion for KIP-763: Range queries with open endpoints. The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-763%3A+Range+queries+with+open+endpoints Any feedback will be highly appreciated. Many thanks, Patrick

Re: [DISCUSS] KIP-763: Range queries with open endpoints

#x27;d also support you. In that case, it might > > be a good idea to simply mention in the "Rejected > > Alternatives" that you decided not to address those other > > store APIs at this time. That way, people later on won't > > have to wonder why those o

[VOTE] KIP-763: Range queries with open endpoints

Hi all, Thanks for the feedback on the KIP, I have updated the KIP and would like to start the voting. The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-763%3A+Range+queries+with+open+endpoints Please vote in this thread. Thanks! -Patrick

Re: [VOTE] KIP-763: Range queries with open endpoints

gt; Best, > > > Bruno > > > > > > On 22.07.21 03:47, Luke Chen wrote: > > > > Hi Patrick, > > > > I like this KIP! > > > > > > > > +1 (non-binding) > > > > > > > > Luke > > > > &g

Re: [DISCUSS] KIP-763: Range queries with open endpoints

or open-ended range queries, could it potentially hide bugs > in the user's code when their intention was to do a bounded range query but > accidentally set the key to null? > > Boyang > > On Wed, Jul 21, 2021 at 2:59 AM Patrick Stuedi > > wrote: > > > Thanks John,

[DISCUSS] KIP-791: Add Record Metadata to State Store Context

Hi everyone, I would like to start the discussion for KIP-791: Add Record Metadata to State Store Context. The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-791:+Add+Record+Metadata+to+State+Store+Context Any feedback will be highly appreciated. Many thanks, Patr

[VOTE] KIP-791: Add Record Metadata to State Store Context

Hi all, Thanks for the feedback on KIP-791, I have updated the KIP and would like to start the voting. The KIP can be found here: https://cwiki.apache.org/confluence/x/I5BnCw Please vote in this thread. Thanks! -Patrick

Re: [VOTE] KIP-791: Add Record Metadata to State Store Context

> On Mon, Nov 8, 2021 at 10:00 AM Luke Chen wrote: > >>> > >>>> Hi Patrick, > >>>> Thanks for the KIP. > >>>> Adding RecordMetadata into StateStoreContext for offset updating makes > >>>> sense to me. > >>>>

Re: [DISCUSS] KIP-796: Interactive Query v2

Hi John, Thanks for submitting the KIP! One question I have is, assuming one instantiates InteractiveQueryRequest via withQuery, and then later calls getPositionBound, what will the result be? Also I noticed the Position returning method is in InteractiveQueryRequest and InteractiveQueryResult is

Re: [VOTE} KIP-796: Interactive Query v2

+1 (non-binding), thanks John! -Patrick On Thu, Nov 18, 2021 at 12:27 AM John Roesler wrote: > Hello all, > > I'd like to open the vote for KIP-796, which proposes > a revamp of the Interactive Query APIs in Kafka Streams. > > The proposal is here: > https://cwiki.apache.org/confluence/x/34xnCw

[VOTE] KIP-806: Add session and window query over KV-store in IQv2

Hi everyone, I would like to start the vote for KIP-806 that adds window and session query support to query KV-stores using IQv2. The KIP can be found here: https://cwiki.apache.org/confluence/x/LJaqCw Skipping the discussion phase as this KIP is following the same pattern as the previously subm

Re: [VOTE] KIP-806: Add session and window query over KV-store in IQv2

gt; Thank you. > > > Luke > > > > > > > > > On Sat, Dec 11, 2021 at 7:54 AM Guozhang Wang > > wrote: > > > > > > > Hi Patrick, > > > > > > > > I made a pass on the KIP and have a few comments below: > >

Re: [VOTE] KIP-806: Add session and window query over KV-store in IQv2

st pressing concerns to > >>>> me were the cases where Luke and Guozhang pointed out that > >>>> some parts of the proposal or interfaces were ambiguous, > >>>> which looks like it's fixed now. > >>>> > >>>> My preference would be

[jira] [Created] (KAFKA-13605) Checkpoint position in state stores

Patrick Stuedi created KAFKA-13605: -- Summary: Checkpoint position in state stores Key: KAFKA-13605 URL: https://issues.apache.org/jira/browse/KAFKA-13605 Project: Kafka Issue Type

[jira] [Created] (KAFKA-13130) Deprecate long based range queries in SessionStore

Patrick Stuedi created KAFKA-13130: -- Summary: Deprecate long based range queries in SessionStore Key: KAFKA-13130 URL: https://issues.apache.org/jira/browse/KAFKA-13130 Project: Kafka Issue

[jira] [Created] (KAFKA-13426) Add recordMetadata to StateStoreContext

Patrick Stuedi created KAFKA-13426: -- Summary: Add recordMetadata to StateStoreContext Key: KAFKA-13426 URL: https://issues.apache.org/jira/browse/KAFKA-13426 Project: Kafka Issue Type

[jira] [Created] (KAFKA-13493) Session and Window Queries for IQv2

Patrick Stuedi created KAFKA-13493: -- Summary: Session and Window Queries for IQv2 Key: KAFKA-13493 URL: https://issues.apache.org/jira/browse/KAFKA-13493 Project: Kafka Issue Type

[jira] [Created] (KAFKA-13494) Session and Window Queries for IQv2

Patrick Stuedi created KAFKA-13494: -- Summary: Session and Window Queries for IQv2 Key: KAFKA-13494 URL: https://issues.apache.org/jira/browse/KAFKA-13494 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-13541) Make IQv2 query/store interface type safe

Patrick Stuedi created KAFKA-13541: -- Summary: Make IQv2 query/store interface type safe Key: KAFKA-13541 URL: https://issues.apache.org/jira/browse/KAFKA-13541 Project: Kafka Issue Type