Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

2019-04-19 Thread Lei Chen
Congratulations Matthias! Well deserved! -Lei On Fri, Apr 19, 2019 at 2:55 PM James Cheng wrote: > Congrats!! > > -James > > Sent from my iPhone > > > On Apr 18, 2019, at 2:35 PM, Guozhang Wang wrote: > > > > Hello Everyone, > > > > I'm glad to announce that Matthias J. Sax is now a member of

Re: [DISCUSS] KIP-362: Dynamic Session Window Support

2018-12-15 Thread Lei Chen
> > Let's see what others think. > > > > One tricky question we would need to address is, how we can be backward > > compatible. I am currently working on KIP-258 that should help to > > address this backward compatibility issue though. > > > > > > -Matthi

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

2018-09-21 Thread Lei Chen
Hi, Just want to know is anyone actively working on this and also KAFKA-4835 ? Seems like the JIRA has been inactive for couple months. We want this feature and would like to move it forward if no one else is working on it. Lei On Wed, Jun 20,

Re: [DISCUSS] KIP-362: Dynamic Session Window Support

2018-09-19 Thread Lei Chen
atm how to do this. However, only consider (15,3) would > result in inconsistencies for out-of-order data as pointed out above and > would not be sufficient. > > > Does this make sense? > > > Or is there another way to define dynamic session gap semantics in a > deterministi

Re: [DISCUSS] KIP-362: Dynamic Session Window Support

2018-08-30 Thread Lei Chen
d we store it, and what would be the upgrade path if it is not a > compatible change on disk storage etc? > > > > Guozhang > > > > On Wed, Aug 22, 2018 at 10:05 AM, Lei Chen wrote: > > > Hi All, > > > > I created a KIP to add dynamic gap session w

[jira] [Created] (KAFKA-7325) Support dynamic gap session window

2018-08-22 Thread Lei Chen (JIRA)
Lei Chen created KAFKA-7325: --- Summary: Support dynamic gap session window Key: KAFKA-7325 URL: https://issues.apache.org/jira/browse/KAFKA-7325 Project: Kafka Issue Type: Improvement

[DISCUSS] KIP-362: Dynamic Session Window Support

2018-08-22 Thread Lei Chen
Hi All, I created a KIP to add dynamic gap session window support to Kafka Streams DSL. https://cwiki.apache.org/confluence/display/KAFKA/KIP-362%3A+Support+dynamic+gap+session+window Please take a look, Thanks, Lei

access for KIP

2018-06-20 Thread Lei Chen
Hi, there, I'd like to request permission to the kafka space in our ASF cwiki, to be able to create KIPs. Username: leyncl email: ley...@gmail.com Thanks!