Tests to emulate leader change(investigation of KAFKA-7680)

2018-12-23 Thread Nikolay Izhikov
Hello, Guys. I started investigating of KAFKA-7680 [1] Jun Rao wrote that this issue can be reproduced with leader change. Please, give me the advice. How can I emulate leader change in tests? Do we have some existing tests I can look into? [1] https://issues.apache.org/jira/browse/KAFKA-7680

Re: SessionWindows type base class

2018-12-23 Thread Boyang Chen
yep this is great, thanks Mattihas! Get Outlook for iOS From: Matthias J. Sax Sent: Sunday, December 23, 2018 11:27 AM To: dev@kafka.apache.org Subject: Re: SessionWindows type base class `Windows` is not a generic window type for all

Re: SessionWindows type base class

2018-12-23 Thread Matthias J. Sax
`Windows` is not a generic window type for all windows. It's only used for windows that can be "pre computed", ie, the window boundaries are know a-priory (like TimeWindow or UnlimitedWindow). We need to distinguish between TimeWindow/UnlimitedWindow and SessionWindows in the API. There are two