diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt
index b7e3bb692..a38fd30e2 100644
--- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt
+++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt
@@ -5,8 +5,8 @@ import io.micrometer.core.instrument.Tags
 import io.micrometer.core.instrument.noop.NoopTimer
 
 val noopTimer = NoopTimer(Meter.Id("", Tags.empty(), null, null, Meter.Type.TIMER))
-const val REACTOR_METRIC = "reactor.stats"
-const val REACTOR_DISCARDED_METRIC = "reactor.discarded"
+const val REACTOR_METRIC = "reactor.stream.stats"
+const val REACTOR_DISCARDED_METRIC = "reactor.stream.discarded"
 const val SERVICES_STATE_METRIC = "services.state"
 const val SERVICES_STATE_ERRORS_METRIC = "services.state.errors.total"
 const val SNAPSHOT_METRIC = "snapshot"
diff --git a/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt b/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt
index 7e554b087..d58fd836a 100644
--- a/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt
+++ b/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt
@@ -99,9 +99,9 @@ class ReactorUtilsTest {
         assertThat(received.await(2, TimeUnit.SECONDS)).isTrue()
 
         val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_DISCARDED_METRIC)
-            .tags(Tags.of( METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
+            .tags(Tags.of(METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
         val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_DISCARDED_METRIC)
-            .tags(Tags.of( METRIC_EMITTER_TAG, "latest")).counter()?.count()
+            .tags(Tags.of(METRIC_EMITTER_TAG, "latest")).counter()?.count()
 
         /**
          * Published by range: (0..10)