diff --git a/src/go/mqtt/mqtt.go b/src/go/mqtt/mqtt.go
index 6f27565..c4a89a2 100644
--- a/src/go/mqtt/mqtt.go
+++ b/src/go/mqtt/mqtt.go
@@ -29,6 +29,7 @@ func init() {
 type data struct {
 	Epoch     int64
 	Timestamp string
+	Client    string
 	Topic     string
 	Value     any
 }
@@ -208,6 +209,7 @@ func (this *MQTTClient) Run(ctx context.Context, pubEndpoint, _ string) error {
 					pdata := data{
 						Epoch:     tstamp.Unix(),
 						Timestamp: tstamp.Format(this.timestampTmpl),
+						Client:    this.id,
 						Topic:     topic,
 						Value:     val,
 					}