[jira] [Created] (STORM-498) storm-kafka: make ZK connection timeout configurable in Kafka spout

[Michael Noll (JIRA)]

Michael Noll created STORM-498:
----------------------------------

             Summary: storm-kafka: make ZK connection timeout configurable in 
Kafka spout
                 Key: STORM-498
                 URL: https://issues.apache.org/jira/browse/STORM-498
             Project: Apache Storm (Incubating)
          Issue Type: Improvement
    Affects Versions: 0.9.3-incubating
            Reporter: Michael Noll
            Assignee: Michael Noll
            Priority: Minor


Currently the Kafka spout uses a hardcoded ZK connection timeout of 15 seconds 
in {{external/storm-kafka/src/jvm/storm/kafka/DynamicBrokersReader.java}}:

{code}
            _curator = CuratorFrameworkFactory.newClient(
                    zkStr,
                    
Utils.getInt(conf.get(Config.STORM_ZOOKEEPER_SESSION_TIMEOUT)),
                    15000,
                    new 
RetryNTimes(Utils.getInt(conf.get(Config.STORM_ZOOKEEPER_RETRY_TIMES)),
                            
Utils.getInt(conf.get(Config.STORM_ZOOKEEPER_RETRY_INTERVAL))));
{code}

We should make this setting configurable, similar to the ZK session timeout 
setting.



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