Hi there,

I tried out Local DRPC similar to the example
https://github.com/apache/storm/blob/0a5a069c6223bdb1e7b9318f208c1b29cb302560/examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentKafkaWordCount.java

It's working well. Eventually I need to query state remotely from hosts
outside storm cluster.
But not able to find any example after checking through storm code so far.
Only local drpc is supported by trident?

Anyone has great example that can work out?


-- 
Regards,
Qili Chen (Cheney)

E-mail: tbcql1...@gmail.com
MP: (+1) 4086217503

Reply via email to