I have created a simple topology ----- TopologyBuilder builder = new TopologyBuilder();
// LocalDRPC drpc = new LocalDRPC(); commented on purpose // DRPCSpout spout = new DRPCSpout("update_data", drpc); DRPCSpout spout = new DRPCSpout("update_data"); builder.setSpout("drpc", spout); // Rest of the code StormSubmitter.submitTopologyWithProgressBar("topo1", conf, builder.createTopology()); ------- While deploying the topology remotely. how do tell the spout , which drpc server to connect to ? I only have storm drpc server running in nimbus host. While checking the drpc log, I do not see any drpc request , my python storm drpc client is making. This works perfectly fine , when run locally. ./Rahul