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 
6fb33afff976e467bfa8e0b29eb82770a2a3aaec
    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
    


Reply via email to