Re: Streams 'External source topic not found' while using groupBy/aggregate

2016-08-15 Thread Mathieu Fenniak
Hi Guozhang, I tested your backport branch, and it looks like it works fine. The same code that was producing the "Invalid topology building" error is working correctly against your branch, just like it is with trunk. Mathieu On Sun, Aug 14, 2016 at 11:25 PM, Guozhang Wang wrote: > Hi Mathie

Re: Streams 'External source topic not found' while using groupBy/aggregate

2016-08-14 Thread Guozhang Wang
Hi Mathieu, I have a PR against 0.10.0 branch to backport the bug fix plus some refactoring, feel free to try it out: https://github.com/apache/kafka/pull/1735 Guozhang On Wed, Aug 10, 2016 at 2:28 PM, Mathieu Fenniak < mathieu.fenn...@replicon.com> wrote: > Hi Guozhang, > > Yes, it does

Re: Streams 'External source topic not found' while using groupBy/aggregate

2016-08-10 Thread Mathieu Fenniak
Hi Guozhang, Yes, it does seem to be fixed in trunk. Thanks. I should have tried that, but I assumed that the recently released 0.10.0.1 would be pretty close to trunk. I can see where that was mistaken, since 0.10.0 is quite divergent from trunk. Mathieu On Wed, Aug 10, 2016 at 2:39 PM, Guo

Re: Streams 'External source topic not found' while using groupBy/aggregate

2016-08-10 Thread Guozhang Wang
Hello Mathieu, I think this issue is fixed in trunk but may get missed in the 0.10.0 branch, could you try running your program from trunk to verify if it is the case? If yes we can consider backportting the hotfix from trunk to 0.10.0 and have another bug fix release. Guozhang On Wed, Aug 10,

Streams 'External source topic not found' while using groupBy/aggregate

2016-08-10 Thread Mathieu Fenniak
Hey there, Kafka Users, I'm trying to join two topics with Kafka Streams. The first topic is a changelog of one object, and the second is a changelog of a related object. In order to join these tables, I'm grouping the second table by a piece of data in it that indicates what record it is relate