Re: kafka unable to send records - scala / spark

2016-07-12 Thread Mudit Agarwal
Sumit,You need to mention arguments as well.You are passing empty list.for ex: props.put("bootstrap.servers", "localhost:9092") From: Sumit Khanna <sumit.kha...@askme.in> To: users@kafka.apache.org Sent: Tuesday, 12 July 2016 4:49 PM Subject: kafka unab

Re: kafka unable to send records - scala / spark

2016-07-12 Thread R Krishna
Try increasing timeouts. On Jul 12, 2016 7:40 AM, "Sumit Khanna" wrote: > Hello Guys. > > Have tried a lot, from kafka.javaapi. etc to Producer to KafkaProducer, and > am working with 0.9.0.0 > This is the error I am getting : > >