From f7a3aab794ca76bb81ebb3dd67f74b052c7db6ff Mon Sep 17 00:00:00 2001
From: Slaven Rezic <slaven.rezic@idealo.de>
Date: Wed, 27 Mar 2019 11:45:44 +0100
Subject: [PATCH] add Kafka::Message::timestamp
---
Rdkafka.xs | 9 +++++++++
lib/Kafka/Librd.pm | 4 ++++
2 files changed, 13 insertions(+)
diff --git a/Rdkafka.xs b/Rdkafka.xs
index 3b13406..5fe3f67 100644
--- a/Rdkafka.xs
+++ b/Rdkafka.xs
@@ -392,6 +392,15 @@ krdm_offset(msg)
OUTPUT:
RETVAL
+long
+krdm_timestamp(msg)
+ rd_kafka_message_t* msg
+ CODE:
+ rd_kafka_timestamp_type_t tstype;
+ RETVAL = rd_kafka_message_timestamp(msg, &tstype);
+ OUTPUT:
+ RETVAL
+
void
krdm_DESTROY(msg)
rd_kafka_message_t* msg
diff --git a/lib/Kafka/Librd.pm b/lib/Kafka/Librd.pm
index c96e129..df542fd 100644
--- a/lib/Kafka/Librd.pm
+++ b/lib/Kafka/Librd.pm
@@ -233,6 +233,10 @@ return message key
return message payload
+=head2 timestamp
+
+return message timestamp (milliseconds since UNIX epoch)
+
=cut
package Kafka::Librd;