We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 069a26a commit e563a93Copy full SHA for e563a93
spring-kafka/src/test/java/org/springframework/kafka/config/KafkaStreamsCustomizerTests.java
@@ -100,7 +100,7 @@ public void testKafkaStreamsCustomizer(@Autowired KafkaStreamsConfiguration conf
100
.functionCounter()
101
.count())
102
.isGreaterThanOrEqualTo(0);
103
- assertThat(this.meterRegistry.get("kafka.producer.node.incoming.byte.total")
+ assertThat(this.meterRegistry.get("kafka.producer.incoming.byte.total")
104
.tag("customTag", "stream")
105
.tag("spring.id", KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_BUILDER_BEAN_NAME)
106
0 commit comments