spark streaming - Kafka latency in Python -


i working on identifying latency of individual messages in given kafka stream, using guid/id of each message passing through stream. assuming each message sent producer has guid in value. so, finding difference in timestamps latency of 2 incoming , outgoing messages matching guids. correct way or understanding wrong? in advance..


Comments