Add support for timestamp in delivery report

Blizzard · Jun 17, 2018 · e0ff088 · e0ff088
1 parent 9cd5cab
commit e0ff088
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/src/callbacks.cc b/src/callbacks.cc
@@ -317,6 +317,11 @@ void DeliveryReportDispatcher::Flush() {
       delete persistent;
     }
 
+    if (event.timestamp > -1) {
+      Nan::Set(jsobj, Nan::New("timestamp").ToLocalChecked(),
+              Nan::New<v8::Number>(event.timestamp));
+    }
+
     if (event.m_include_payload) {
       if (event.payload) {
         Nan::MaybeLocal<v8::Object> buff = Nan::NewBuffer(
@@ -359,6 +364,14 @@ DeliveryReport::DeliveryReport(RdKafka::Message &message, bool include_payload)
   partition = message.partition();
   offset = message.offset();
 
+  if (message.timestamp().type !=
+    RdKafka::MessageTimestamp::MSG_TIMESTAMP_NOT_AVAILABLE) {
+    timestamp = message.timestamp().timestamp;
+  } else {
+    timestamp = -1;
+  }
+
+
   // Key length.
   key_len = message.key_len();
 

diff --git a/src/callbacks.h b/src/callbacks.h
@@ -110,6 +110,7 @@ class DeliveryReport {
   std::string topic_name;
   int32_t partition;
   int64_t offset;
+  int64_t timestamp;
 
   // Opaque token used. Local value
   void* opaque;