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.