subject:"Extract timestamp from Kafka message"

Re: Extract timestamp from Kafka message

2016-09-26 Thread Alonso Isidoro Roman

59 GMT+02:00 Kevin Tran : > Hi Everyone, > Does anyone know how could we extract timestamp from Kafka message in > Spark streaming ? > > JavaPairInputDStream messagesDStream = > KafkaUtils.createDirectStream( >ssc, >String.class, >

Extract timestamp from Kafka message

2016-09-25 Thread Kevin Tran

Hi Everyone, Does anyone know how could we extract timestamp from Kafka message in Spark streaming ? JavaPairInputDStream messagesDStream = KafkaUtils.createDirectStream( ssc, String.class, String.class, StringDecoder.class, StringDecoder.class