From aaf3899f925b8f598782c54c6c08b6962627b1f1 Mon Sep 17 00:00:00 2001 From: Pedro Melo Date: Tue, 13 Oct 2020 22:48:30 +0100 Subject: [PATCH] Document timestamp() ::Message method --- lib/Net/Kafka.pm | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/lib/Net/Kafka.pm b/lib/Net/Kafka.pm index 8b3add5..03afc1a 100644 --- a/lib/Net/Kafka.pm +++ b/lib/Net/Kafka.pm @@ -433,6 +433,15 @@ support 64 bit integers. return message key +=item timestamp() + + my ($ts, $ts_type) = $msg->timestamp(); + + return the timestamp (in miliseconds) and the timestamp type. The timestamp + type is one of the constants that we can import, + C, C or + C. + =item payload() return message payload