I'm beginner in this but here you are storm-starter contains some examples of doing DRPC:
https://github.com/nathanmarz/storm-starter/blob/master/src/ jvm/storm/starter/BasicDRPCTopology.java https://github.com/nathanmarz/storm-starter/blob/master/src/ jvm/storm/starter/ReachTopology.java and if someone else has a good experience can help us , I hope that On Thu, Jun 29, 2017 at 12:12 AM, Pauley, Jim <[email protected]> wrote: > Can I restate your question and ask what is the simplest working example > of DRPC out there? Seems like you need a LocalDRPC submitted as a Topology > and on that same Storm setup a DRPC server needs to be configured with > public IP{. and on a separate JVM a simple jar running DrpcClient trying to > connect to that LocalDRPC public IP. I'd like to see a simple working > example of LocalDRPC and DRPCClient but have not found one. I would like to > extend it to make a REST API to query results from my topology.. Any ideas > appreciated. > > ------------------------------ > *From:* sam mohel [[email protected]] > *Sent:* Wednesday, June 28, 2017 4:41 PM > *To:* [email protected]; [email protected] > *Subject:* [EXTERNAL] Drpc configuration > > I need to know configurations of drpc as I read more about it and every > time I read different settings. > Now if I have 2 machines . Machine A and B . In machine A I will run > nimbus and drpc and ui . But in B I will run supervisor . > In the code I made drpc.servers has IP address of A and drpc client has > same IP too. Nimbus.host has same IP and zookeeper.severs too . And in > /etc/hosts I defined IP address with name and IP address of B with it's > name and this copied to /etc/hosts in B too . I didn't receive results > after this configurations . Is something wrong here ? >
