Hello Taylor, 1) I am not overriding anything. 2) You are right. I did notice the mistake and fixed it, but, now I am in the same situation as in (1).
thanks, Clay On Tue, May 26, 2015 at 10:49 AM, P. Taylor Goetz <ptgo...@gmail.com> wrote: > 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 <clayteaho...@gmail.com> 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 > > > > >
