title: Using storm-kafka-0.8-plus , only a few spouts actually pull data
body: <p>I have been using storm-kafka-0.8-plus with kafka 0.8.1.1 &amp; storm 0.9.0.1 (zmq reason.). I have also used the spout with other versions of storm. But the issue is only a few of the threads actually work and others remain idle. I have no clue why this is happening.</p>
  
  <pre><code>public static void main(String[] args) throws Exception {
      brokerHosts = new ZkHosts(CONFIGURATION.getString("ZK_HOSTS") + "/"
              + CONFIGURATION.getString("ZK_CONNECT_PATH"));
      SpoutConfig spoutConfig = new SpoutConfig(brokerHosts,
              CONFIGURATION.getString("KAFKA_TOPIC"),
              CONFIGURATION.getString("ZOOKEEPER_STORAGE_PATH"),
              CONFIGURATION.getString("ZOOKEEPER_STORAGE_ID"));
      spoutConfig.startOffsetTime = kafka.api.OffsetRequest.LatestTime();
      KafkaSpout kafkaspout = new KafkaSpout(spoutConfig);
  
      TopologyBuilder builder = new TopologyBuilder();
      builder.setSpout("kafka-spout", kafkaspout,
              CONFIGURATION.getInt("NUM_KAFKA_SPOUT_THREADS"));
  
      Config config = new Config();
      StormSubmitter.submitTopology(CONFIGURATION.getString("TOPOLOGY_NAME"),
              config, builder.createTopology());
  }
  </code></pre>
  
  <p>pom.xml</p>
  
  <pre><code>&lt;dependency&gt;
    &lt;groupId&gt;storm&lt;/groupId&gt;
    &lt;artifactId&gt;storm&lt;/artifactId&gt;
    &lt;version&gt;0.9.0.1&lt;/version&gt;
    &lt;scope&gt;provided&lt;/scope&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
    &lt;groupId&gt;net.wurstmeister.storm&lt;/groupId&gt;
    &lt;artifactId&gt;storm-kafka-0.8-plus&lt;/artifactId&gt;
    &lt;version&gt;0.4.0&lt;/version&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
    &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
    &lt;artifactId&gt;kafka_2.10&lt;/artifactId&gt;
    &lt;version&gt;0.8.1&lt;/version&gt;
  &lt;/dependency&gt; 
  </code></pre>