From 2ab2e06e7fc8510ca5dbcb646b7ac976a073308b Mon Sep 17 00:00:00 2001
From: dspeck1 <dspeck@burwood.com>
Date: Thu, 21 Nov 2024 16:07:20 -0600
Subject: [PATCH] Add time to header for load time tracking.

---
 src/main.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main.py b/src/main.py
index b190eb6..2d37655 100644
--- a/src/main.py
+++ b/src/main.py
@@ -352,9 +352,11 @@ def dispatch_fanned_out_messages(client: httpx.AsyncClient,
         Whether or not Knative requests can be retried.
     """
     try:
+
         attributes = {
             "type": "com.example.kafka",
             "source": topic,
+            "time": str(time.time())
         }
 
         for fan_out_message in send_info.fan_out_messages: