Hi Nikolai, Thanks for responding, That is good idea but we are having some metric for the kafka messages and i don't want to put the our common jar into the classpath of the ignite. For now, I am sending all the messages in one go to as Json String. So that also reduces the network round as well.
On Mon, Jun 5, 2017 at 1:58 PM, Nikolai Tikhonov <[email protected]> wrote: > 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.705 >> 18.x6.nabble.com/Best-way-to-send-records-to-Kafka-from-Dat >> aStreamer-Receiver-tp13291.html >> Sent from the Apache Ignite Users mailing list archive at Nabble.com. >> > >
