Craig Bryant 9050956a3b Have to use a different consumer.id for each instance of a KafkaSpout so use the storm taskId. Otherwise, zookeeper complains about a conflicted ephemeral node when there is more than one spout reading from a topic ...

Have two metric and event spouts to make sure the messages stop coming out. More like the real configuration.

2014-05-01 13:44:43 -06:00

..

deb

JIRA JAH-17 Modify maven build for mon-thresh that creates a jar that can be used for a production build.

2014-04-30 22:28:12 -06:00

main

Have to use a different consumer.id for each instance of a KafkaSpout so use the storm taskId. Otherwise, zookeeper complains about a conflicted ephemeral node when there is more than one spout reading from a topic

2014-05-01 13:44:43 -06:00

test

JIRA JAH-17 Modify maven build for mon-thresh that creates a jar that can be used for a production build.

2014-04-30 22:28:12 -06:00