title: KafkaSpout is not receiving anything from Kafka
body: <p>I am trying to rig up a a Kafka-Storm "Hello World" system. I have Kafka installed and running, when I send data with the Kafka producer I can read it with the Kafka console consumer.</p>
  
  <p>I took the Chapter 02 example from the "Getting Started With Storm" O'Reilly book, and modified it to use KafkaSpout instead of a regular spout.</p>
  
  <p>When I run the application, with data already pending in kafka, nextTuple of the KafkaSpout doesn't get any messages - it goes in, tries to iterate over an empty managers list under the coordinator, and exits.</p>
  
  <p>My environment is a fairly old Cloudera VM, with Storm 0.9 and Kafka-Storm-0.9(the latest), and Kafka 2.9.2-0.7.0.</p>
  
  <p>This is how I defined the SpoutConfig and the topology:</p>
  
  <pre><code>String zookeepers = "localhost:2181";
  
  SpoutConfig spoutConfig = new SpoutConfig(new SpoutConfig.ZkHosts(zookeepers, "/brokers"),
          "gtest",
          "/kafka",  // zookeeper root path for offset storing
          "KafkaSpout");
  spoutConfig.forceStartOffsetTime(-1);
  
  KafkaSpoutTester kafkaSpout = new KafkaSpoutTester(spoutConfig);
  
  
  //Topology definition
  TopologyBuilder builder = new TopologyBuilder();
  builder.setSpout("word-reader", kafkaSpout, 1);
  builder.setBolt("word-normalizer", new WordNormalizer())
      .shuffleGrouping("word-reader");
  builder.setBolt("word-counter", new WordCounter(),1)
      .fieldsGrouping("word-normalizer", new Fields("word"));
  
  //Configuration
  Config conf = new Config();
  conf.put("wordsFile", args[0]);
  conf.setDebug(false);
  //Topology run
  conf.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, 1);
  cluster = new LocalCluster();
  cluster.submitTopology("Getting-Started-Toplogie", conf, builder.createTopology());
  </code></pre>
  
  <p>Can someone please help me figure out why I am not receiving anything?</p>
  
  <p>Thanks,
  G.</p>