diff --git a/tests/unit/test_connection.py b/tests/unit/test_connection.py
index a3ffed06bb..2adc98f448 100644
--- a/tests/unit/test_connection.py
+++ b/tests/unit/test_connection.py
@@ -492,6 +492,7 @@ class TestMQTTConnection(ZuulTestCase):
         self.assertIn('timestamp', mqtt_payload)
         self.assertIn('enqueue_time', mqtt_payload)
         self.assertIn('trigger_time', mqtt_payload)
+        self.assertIn('zuul_event_id', mqtt_payload)
         self.assertEquals(dependent_test_job['dependencies'], ['test'])
 
     def test_mqtt_invalid_topic(self):
diff --git a/zuul/driver/mqtt/mqttreporter.py b/zuul/driver/mqtt/mqttreporter.py
index f5ab6e4a5e..fd7f6d30fa 100644
--- a/zuul/driver/mqtt/mqttreporter.py
+++ b/zuul/driver/mqtt/mqttreporter.py
@@ -49,6 +49,7 @@ class MQTTReporter(BaseReporter):
                 'uuid': item.current_build_set.uuid,
                 'builds': []
             },
+            'zuul_event_id': item.event.zuul_event_id,
         }
         for job in item.getJobs():
             job_informations = {