flux

[clay teahouse]

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