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 f852c28 commit 99ac717Copy full SHA for 99ac717
spring-kafka/src/main/java/org/springframework/kafka/support/micrometer/KafkaListenerObservation.java
@@ -231,7 +231,7 @@ public KeyValues getLowCardinalityKeyValues(KafkaRecordReceiverContext context)
231
KeyValues keyValues = KeyValues.of(
232
ListenerLowCardinalityTags.LISTENER_ID.withValue(context.getListenerId()),
233
ListenerLowCardinalityTags.MESSAGING_SYSTEM.withValue("kafka"),
234
- ListenerLowCardinalityTags.MESSAGING_OPERATION.withValue("receive"),
+ ListenerLowCardinalityTags.MESSAGING_OPERATION.withValue("process"),
235
ListenerLowCardinalityTags.MESSAGING_SOURCE_NAME.withValue(context.getSource()),
236
ListenerLowCardinalityTags.MESSAGING_SOURCE_KIND.withValue("topic")
237
);
0 commit comments