Kaffffka sparkk streaming hbase

[panipoori]

3 minutes ago, vendettaa said:

val messages = KafkaUtils.createDirectStream[String, String](
  ssc,
  LocationStrategies.PreferConsistent,
  ConsumerStrategies.Subscribe[String, String](topicsSet, kafkaParams))
val lines = messages.map(_.value)
import sqlContext.implicits._

lines.foreachRDD(rdd => rdd.foreach(println))
println("44444444444444444")
lines.foreachRDD(raw=>{
   val xy = raw.map(_.value.toString)
   val df =sqlContext.read.json(xy)
 })

 

ikda Error:(148, 27) value value is not a member of String
       val xy = raw.map(_.value.toString)

 

😫😫

nee daggara answer vndi ga keep changing the value of the variable till the function works

[vendettaa]

3 minutes ago, panipoori said:

nee daggara answer vndi ga keep changing the value of the variable till the function works

ni moham ni moham teliyakapote chup

[panipoori]

39 minutes ago, vendettaa said:

ni moham ni moham teliyakapote chup

[vendettaa]

Finally cracked it 

but I have to upgrade version