Hi Clay, 1) Are you overriding the default sleep time for local topologies with the `-s` option followed by the sleep time in milliseconds? If so, with what value? By default, flux will run local mode topologies for 60 seconds.
2) It looks like you are trying to use KafkaConfig with constructor arguments for SpoutConfig. The SpoutConfig class extends KafkaConfig and has a different constructor signature: public KafkaConfig(BrokerHosts hosts, String topic) public KafkaConfig(BrokerHosts hosts, String topic, String clientId) public SpoutConfig(BrokerHosts hosts, String topic, String zkRoot, String id) -Taylor On May 26, 2015, at 7:35 AM, clay teahouse <[email protected]> wrote: > Hi All, > > I am trying to test flux module for writing template driven topologies. I > setting the topologies in localcluster mode. > 1) using template simple_wordcount.yaml > 2) using kafka_spout.yaml (using TestBolt) > > With (1) I don't get any output form TestBolt and the topology exits. > With (2), I get the following error: > java.lang.IllegalArgumentException: Couldn't find a suitable constructor for > class 'storm.kafka.KafkaConfig' with arguments > '[storm.kafka.ZkHosts@17d1e01f, TOPIC, /storm, myKafkaClientId]\ > > > > Any idea what I could be doing wrong? > > > > thanks > > Clay > > > >
signature.asc
Description: Message signed with OpenPGP using GPGMail
