Re: KafkaProducer using Cassandra as source
", "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
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)