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
signature.asc
Description: OpenPGP digital signature
