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.
