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