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

Reply via email to