diff --git a/pkg/monitoring/InfluxDbStorage.php b/pkg/monitoring/InfluxDbStorage.php
index 401d79ddb..ff5f6c3b0 100644
--- a/pkg/monitoring/InfluxDbStorage.php
+++ b/pkg/monitoring/InfluxDbStorage.php
@@ -160,6 +160,16 @@ public function pushConsumedMessageStats(ConsumedMessageStats $stats): void
             'status' => $stats->getStatus(),
         ];
 
+        $properties = $stats->getProperties();
+
+        if (false === empty($properties[Config::TOPIC])) {
+            $tags['topic'] = $properties[Config::TOPIC];
+        }
+
+        if (false === empty($properties[Config::COMMAND])) {
+            $tags['command'] = $properties[Config::COMMAND];
+        }
+
         $values = [
             'receivedAt' => $stats->getReceivedAtMs(),
             'processedAt' => $stats->getTimestampMs(),