hum, i think you have to embed the timestamp within the message... Alonso Isidoro Roman [image: https://]about.me/alonso.isidoro.roman <https://about.me/alonso.isidoro.roman?promo=email_sig&utm_source=email_sig&utm_medium=email_sig&utm_campaign=external_links>
2016-09-26 0:59 GMT+02:00 Kevin Tran <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, > String.class, > StringDecoder.class, > StringDecoder.class, > kafkaParams, > topics > ); > > > Thanks, > Kevin. > > > > > > >
