Hi Kali,
If you do not mind sending JSON, you could do something like this, using
json4s:
val rows = p.collect() map ( row => TestTable(row.getString(0),
row.getString(1)) )
val json = parse(write(rows))
producer.send(new KeyedMessage[String, String]("trade", writePretty(json)))
// or for eac
Guys sorry I figured it out.
val
x=p.collect().mkString("\n").replace("[","").replace("]","").replace(",","~")
Full Code:-
package com.examples
/**
* Created by kalit_000 on 22/09/2015.
*/
import kafka.producer.KeyedMessage
import kafka.producer.Producer
import kafka.producer.ProducerConfig
