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.

Reply via email to