Hi All,
I'm getting an invalid topology error when trying to emit from one bolt to
another.
>From the create topology method:
private static String ODU_BOLT = "ODU";
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("msgs", new KafkaSpout(kafkaConfig), 1);
builder.setBolt(CSG_BOLT, new CSGIntakeBolt()).shuffleGrouping("msgs");
//Bolts for message routing
builder.setBolt(ODU_BOLT, new ODUBolt()).shuffleGrouping(CSG_BOLT);
The emit method inside the CSG_BOLT
outputCollector.emit("ODU", tuple.getValues());
But I'm getting the below error...
331 [main] WARN backtype.storm.StormSubmitter - Topology submission
exception: Component: [ODU] subscribes from non-existent stream: [default]
of component [CSG]
Exception in thread "main" InvalidTopologyException(msg:Component: [ODU]
subscribes from non-existent stream: [default] of component [CSG])
Regards,
Nick
