Thanks David, 0.10.1 is planned to be released in Oct, we are following a time-based release cycle moving forward to have more predictable releases.
Guozhang On Tue, Sep 6, 2016 at 8:12 AM, David Garcia <dav...@spiceworks.com> wrote: > Done: https://issues.apache.org/jira/browse/KAFKA-4131 > > Thanks Guozhang for also looking at this. BTW, do you have any idea when > 0.10.1 will be released? > > -David > > > On 9/5/16, 12:14 AM, "Guozhang Wang" <wangg...@gmail.com> wrote: > > Hello David, > > Thanks for reporting this issue, and after some look through the code I > think it is indeed a bug, and commit 6fb33afff976e467bfa8e0b29eb827 > 70a2a3aaec > will not fix it IMHO. > > Would you want to create a JIRA for keeping track of this issue? > > Guozhang > > > On Sat, Sep 3, 2016 at 10:16 AM, David Garcia <dav...@spiceworks.com> > wrote: > > > This bug may be fixed after commit: 6fb33afff976e467bfa8e0b29eb827 > > 70a2a3aaec > > > > When you start two consumer processes with a regex topic (with 2 or > more > > partitions for the matching topics), the second (i.e. nonleader) > consumer > > will fail with a null pointer exception. > > > > Exception in thread "StreamThread-4" java.lang.NullPointerException > > at org.apache.kafka.streams.processor.internals. > > RecordQueue.addRawRecords(RecordQueue.java:78) > > at org.apache.kafka.streams.processor.internals. > > PartitionGroup.addRawRecords(PartitionGroup.java:117) > > at org.apache.kafka.streams.processor.internals. > > StreamTask.addRecords(StreamTask.java:139) > > at org.apache.kafka.streams.processor.internals. > > StreamThread.runLoop(StreamThread.java:299) > > at org.apache.kafka.streams.processor.internals. > > StreamThread.run(StreamThread.java:208) > > > > The issue may be in the TopologyBuilder line 832: > > String[] topics = (sourceNodeFactory.pattern != null) ? > > sourceNodeFactory.getTopics(subscriptionUpdates.getUpdates()) : > > sourceNodeFactory.getTopics(); > > > > Because the 2nd consumer joins as a follower, “getUpdates” returns an > > empty collection and the regular expression doesn’t get applied to > any > > topics. Perhaps this is fixed after?: 6fb33afff976e467bfa8e0b29eb827 > > 70a2a3aaec > > > > -David > > > > > > > > > > > -- > -- Guozhang > > > > -- -- Guozhang