storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Navin Ipe <>
Subject Emit from a Java application and receive in a Bolt of another Java application?
Date Tue, 26 Apr 2016 09:59:18 GMT

A colleague created a Bolt that writes data to a MongoDB application.
I have a Spout that reads that data from MongoDB.
My colleague's Bolt is in a separate Storm application he built. Mine is on
a separate storm application I built. Our applications may run on different

My team lead wants my colleague's Bolt to emit data, and wants a Bolt in my
application to receive that data. So we basically avoid writing to MongoDB.

I suggested doing this via Java sockets, RMI or Redis. On hearing this, my
team lead tells me "You haven't understood Storm yet".

I've been through a lot of the documentation on Storm, and I haven't seen
any case where Storm can communicate. Except maybe using DRPC
But there
But there are complaints of DRPC memory leaks and unexpected behaviour:

So is DRPC the way to go or does Storm have some other method of emitting
from one topology and receiving it in another topology?


View raw message