Kestrel integration with Storm 1.0.1 using KestrelThriftSpout while upgrading from storm 0.82

[John Lukar <jl...@gmail.com>]

Storm website documentation
(http://storm.apache.org/about/integrates.html)   implies
KestrelThriftSpout should work out of the box:
https://github.com/nathanmarz/storm-kestrel

However 1.0.1's   builder.setSpout, does not accept KTS which is based
on backtype.*  package naming which was storm 0.82 package name.

The code below will not compile with the message:          "Wrong 2nd
argument type. Found: 'backtype.storm.spout.KestrelThriftSpout',
required: 'org.apache.storm.topology.IRichSpout' ..."

KTS implements  "backtype.storm.topology.IRichSpout"

Do I need to fork KestrelThriftSpout and port to new Apache 1.0.1 (new
org.apache pacakage names)  or there is another KTS  that works with
Storm 1.0.1 ?

Thanks in advance for your help !!


TopologyBuilder builder = new TopologyBuilder();
builder.setSpout(
      name,
      new KestrelThriftSpout(
            hostsList,
            Integer.parseInt(topologyConfig.getProperty(TOPOLOGY_PORTNUM)),
            name,
            new MySchemeImpl()
      ),
      Integer.parseInt(topologyConfig.getProperty(SPOUT_PARALLELISM)));