Ooops.. so sorry.. I was evaluating Spark as well for this purpose. :) Thanks for the quick answer. Some part of the puzzle has been solved now.
Regards, Chandrash3khar Kotekar Mobile - +91 8600011455 On Wed, Jul 1, 2015 at 5:49 PM, Matthias J. Sax < [email protected]> wrote: > Hi, > > I guess you refer to Apache Storm (not Spark ;)) > > In Storm, there is no special support to notify your client (as far as I > know). The right place to implement the notification should be the > method Spout.ack(). I guess you are using a provided KafkaSpout. Thus, > you could extend KafkaSpout with your own implementation like this: > > class ClientAckKafkaSpout extends KafkaSpout { > @Override > public void ack(Object msgId) { > super.ack(msgId); > // inform client > } > } > > > -Matthias > > > On 07/01/2015 02:14 PM, Chandrashekhar Kotekar wrote: > > Hi, > > > > My application is going to have following flow. client -> apache kafka > > -> Apache Spark -> HBase. > > > > I would like to know what is the best way to send acknowledgement to > > clients using Apache spark for their message? > > > > Should my client systems be listening on some port for acknowledgement? > > > > Can Spark bolt/spout send acknowledgement messages to client systems? > > > > What approach other people follow? > > > > > > Regards, > > Chandrash3khar Kotekar > > Mobile - +91 8600011455 > >
