diff --git a/protos/voltha_protos/events.proto b/protos/voltha_protos/events.proto
index 235a0ec..0ef12a4 100644
--- a/protos/voltha_protos/events.proto
+++ b/protos/voltha_protos/events.proto
@@ -52,6 +52,9 @@
     map<string, string> context = 6; // Name value pairs that provide additional
                                      // context information on the metrics being
                                      // reported.
+
+    string uuid = 7;               // Transaction identifier used to match On
+                                   // Demand gRPC requests with kafka responses
 }
 
 /*
diff --git a/protos/voltha_protos/voltha.proto b/protos/voltha_protos/voltha.proto
index 8fcbb43..b8edd31 100644
--- a/protos/voltha_protos/voltha.proto
+++ b/protos/voltha_protos/voltha.proto
@@ -84,6 +84,19 @@
     repeated CoreInstance items = 1;
 }
 
+message OmciTestRequest {
+    string id = 1;
+    string uuid = 2;
+}
+
+message TestResponse{
+    enum TestResponseResult  {
+        SUCCESS = 0;
+        FAILURE = 1;
+    }
+    TestResponseResult result = 1;
+}
+
 // Voltha represents the Voltha cluster data.  Each Core instance will hold a subset of
 // the entire cluster. However, some items (e.g. adapters) will be held by all cores
 // for better performance
@@ -585,5 +598,12 @@
         };
     }
 
+    // omci start and stop cli implementation
+    rpc StartOmciTestAction(OmciTestRequest) returns(TestResponse) {
+        option (google.api.http) = {
+            post: "/api/v1/start_omci_test"
+            body: "*"
+        };
+    }
 }