http://spark.apache.org/docs/latest/api/java/index.html
messageHandler receives a kafka MessageAndMetadata object. Alternatively, if you just need metadata information on a per-partition basis, you can use HasOffsetRanges http://spark.apache.org/docs/latest/streaming-kafka-integration.html#approach-2-direct-approach-no-receivers On Thu, Aug 25, 2016 at 6:45 AM, Pradeep <pradeep.mi...@mail.com> wrote: > Hi All, > > I am using Dstreams to read Kafka topics. While I can read the messages fine, > I also want to get metadata on the message such as offset, time it was put to > topic etc.. Is there any Java Api to get this info. > > Thanks, > Pradeep > > --------------------------------------------------------------------- > To unsubscribe e-mail: user-unsubscr...@spark.apache.org > --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
