Hi,

You can avoid sending message to local lister. From datastreamer receiver
you can submit a closure (which will send a message to kafka) to another
thread pool.

On Wed, May 31, 2017 at 4:13 PM, fatality <[email protected]> wrote:

> Hi
>
> I am using IgniteDataStreamer to take records and process them via the
> receiver in IgniteDataStreamer and as a result of the process, for some
> records, I would like to send messages into another Kafka Topic inside the
> receiver. Could you please advice a good way to do that or maybe this is
> already possible by using some common library in ignite?
>
> Currently i am using ignite messaging to send records into the
> locallisteners of the datastreamer.But i am not sure if that is a good idea
> once i have huge traffic.
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Best-way-to-send-records-to-Kafka-from-
> DataStreamer-Receiver-tp13291.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Reply via email to