Storm topology, not trident
http://screencast.com/t/YRyEDUqdPhg
kafa spouts (home grown) are showing failed messages, but the bolts have
not failed any.
I even turned off timeouts:
config.put("topology.enable.message.timeouts", false);
but just can not figure out why spout "ora_mile" is not sending messages to
"assign_rowKey" bolt
OraMilestoneSpout oraMileSpout = new
OraMilestoneSpout(oraMilestoneTopic,"exchange-milestones-"+environment);
builder.setSpout(SPOUT_ORA_MILESTONE, oraMileSpout,
oraMilestoneSpoutThreads );
..
AssignRowKeyBolt assignRowKeyBolt = new AssignRowKeyBolt();
builder.setBolt( BOLT_ASSIGN_ROW_KEY, assignRowKeyBolt,
assignRowKeyThreads )
.fieldsGrouping( BOLT_LOAD_ORA_CLAIM,
TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP))
.fieldsGrouping( SPOUT_RAP_MILESTONE,
TopologyConstants.MILESTONES_STREAM, new
Fields(TopologyConstants.FIELD_GROUP))
.fieldsGrouping( SPOUT_RAP_CLAIM,
TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP))
.fieldsGrouping( SPOUT_ORA_MILESTONE,
TopologyConstants.MILESTONES_STREAM, new
Fields(TopologyConstants.FIELD_GROUP))
.fieldsGrouping( BOLT_RAP_PROFILE,
TopologyConstants.PROFILES_STREAM, new
Fields(TopologyConstants.FIELD_GROUP))
.fieldsGrouping( BOLT_CLE_CLAIM_PARSER,
TopologyConstants.CLAIMS_STREAM, new Fields(TopologyConstants.FIELD_GROUP));
Any pointers?
For some reason I only see this on production traffic.
--
Tomas Mazukna
678-557-3834
