subject:"Extract timestamp from Kafka message"

Re: Extract timestamp from Kafka message

2016-09-26 Thread Alonso Isidoro Roman

<kevin...@gmail.com>: > Hi Everyone, > Does anyone know how could we extract timestamp from Kafka message in > Spark streaming ? > > JavaPairInputDStream<String, String> 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<String, String> messagesDStream = KafkaUtils.createDirectStream( ssc, String.class, String.class, StringDecoder.class, StringDecoder