Xingxing Di created STORM-1708:
----------------------------------

             Summary: Replay the kafka messages when no failed tuples.
                 Key: STORM-1708
                 URL: https://issues.apache.org/jira/browse/STORM-1708
             Project: Apache Storm
          Issue Type: Bug
    Affects Versions: 0.10.0, 0.9.5
         Environment: kafka 0.8.1
            Reporter: Xingxing Di


We build topology with OpaqueTridentKafkaSpout,  the configuration is :
        conf.setMaxSpoutPending(2048); 
        conf.setMessageTimeoutSecs(120);

that cause messages replayed lot of times, and there is no failed tuples in 
storm ui. 

After we set :
        conf.setMaxSpoutPending(10); 
        conf.setMessageTimeoutSecs(30);
everyting works fine. 

It confuse a lot , i think it's a major bug.



 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to