Re: Potential KafkaStreaming Bug

2015-11-20 Thread Bill Bejeck
Ok great. I'll get it too it this weekend. Thanks, Bill On Fri, Nov 20, 2015 at 8:04 PM, Guozhang Wang wrote: > Bill, > > Thanks for point it out! I think this is a real bug. Do you want to file PR > in github with the fix? You can find the instructions here: > > https://cwiki.apache.org/confl

Re: Potential KafkaStreaming Bug

2015-11-20 Thread Guozhang Wang
Bill, Thanks for point it out! I think this is a real bug. Do you want to file PR in github with the fix? You can find the instructions here: https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes Guozhang On Fri, Nov 20, 2015 at 8:32 AM, Bill Bejeck wrote: > Hi All, > >

Potential KafkaStreaming Bug

2015-11-20 Thread Bill Bejeck
Hi All, I'm starting to experiment with the lower-level Processor Client API found on the KIP-28 wiki. When starting the KafkaStream I get the following Exception: Exception in thread "main" java.util.NoSuchElementException: id: SINK at org.apache.kafka.streams.processor.internals.QuickUnion.roo