Re: KafkaProducer using Cassandra as source

2015-09-23 Thread kali.tumm...@gmail.com
", "kafka.serializer.StringEncoder") val config= new ProducerConfig(props) val producer= new Producer[String,String](config) val x=p.collect().mkString("\n").replace("[","").replace("]","").replace(",","~&quo

Re: KafkaProducer using Cassandra as source

2015-09-23 Thread Todd Nist
new Properties() > props.put("metadata.broker.list", "localhost:9092") > props.put("serializer.class", "kafka.serializer.StringEncoder") > > val config= new ProducerConfig(props) > val producer= new Producer[String,String](config)