On Mon, Feb 29, 2016 at 6:34 PM, Guozhang Wang wrote:
> Thanks for pointing it out!
My pleasure!
> And yes it is indeed a bug in the code. Could
> you file a HOTFIX PR fixing this and also modify the existing unit test to
> cover this case?
Sorry, I missed your email until
Filed hotfix PR https://github.com/apache/kafka/pull/991.
On Mon, Feb 29, 2016 at 3:34 PM, Guozhang Wang wrote:
> Hi Avi,
>
> Thanks for pointing it out! And yes it is indeed a bug in the code. Could
> you file a HOTFIX PR fixing this and also modify the existing unit test
I was just playing around with Streams’ join features, just to get a
feel for them, and I think I may have noticed a bug in the code, in
KStreamImpl.java on line 310: