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

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 0.9.3
• Fix Version/s: 0.9.3
• Component/s: storm-kafka
• Assignee: Michael G. Noll
• Reporter: Michael G. Noll
• Created: 16/Sep/14 13:25
• Updated: 09/Oct/15 01:18
• Resolved: 09/Oct/15 01:18

Description

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

_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))));

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