retrieve commit time for messages

2015-12-14 Thread sunil kalva
Hi Is there any way to get the commit timestamp of the messages which are retrieved using kafka consumer API. t SunilKalva

Re: retrieve commit time for messages

2015-12-14 Thread Jason Gustafson
At the moment, there is no direct way to do this, but you could use the commit API to include metadata with each committed offset: public void commitSync(final Map offsets); public OffsetAndMetadata committed(TopicPartition partition); The OffsetAndMetadata