We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c935970 commit ea75cbaCopy full SHA for ea75cba
tests/src/test/java/io/streamnative/pulsar/handlers/kop/MetricsProviderTest.java
@@ -230,6 +230,10 @@ public void testMetricsProvider() throws Exception {
230
Assert.assertTrue(sb.toString().contains("kop_server_PRODUCE_MESSAGE_CONVERSIONS{partition=\"0\","
231
+ "topic=\"kopKafkaProducePulsarMetrics1\"} 10"));
232
Assert.assertTrue(sb.toString().contains("kop_server_PRODUCE_MESSAGE_CONVERSIONS_TIME_NANOS"));
233
+
234
+ // network stats
235
+ Assert.assertTrue(sb.toString().contains("NETWORK_TOTAL_BYTES_IN"));
236
+ Assert.assertTrue(sb.toString().contains("NETWORK_TOTAL_BYTES_OUT"));
237
}
238
239
@Test(timeOut = 20000)
0 commit comments