From 9ad2f04ef533f0b1d66ef4d2199004f67c24b71a Mon Sep 17 00:00:00 2001 From: Dragos Misca Date: Mon, 24 Jun 2024 21:06:12 -0700 Subject: [PATCH] [feat][doc] PIP-264: Add replication metrics reference --- docs/reference-metrics-opentelemetry.md | 42 +++++++++++++++++++++++++ 1 file changed, 42 insertions(+) diff --git a/docs/reference-metrics-opentelemetry.md b/docs/reference-metrics-opentelemetry.md index 4f337fcbbf36..e5fff31ed0c0 100644 --- a/docs/reference-metrics-opentelemetry.md +++ b/docs/reference-metrics-opentelemetry.md @@ -478,6 +478,48 @@ The total number of messages dropped from this producer. * `wait_for_exclusive` * `exclusive_with_fencing` +### Replicator metrics + +#### pulsar.broker.replication.message.incoming.count +The total number of messages received from the remote cluster through this replicator. +* Type: Counter +* Unit: `{message}` + +#### pulsar.broker.replication.message.outgoing.count +The total number of messages sent to the remote cluster through this replicator. +* Type: Counter +* Unit: `{message}` + +#### pulsar.broker.replication.message.incoming.size +The total number of messages bytes received from the remote cluster through this replicator. +* Type: Counter +* Unit: `{By}` + +#### pulsar.broker.replication.message.outgoing.size +The total number of messages bytes sent to the remote cluster through this replicator. +* Type: Counter +* Unit: `{By}` + +#### pulsar.broker.replication.message.backlog.count +The total number of messages in the backlog for this replicator. +* Type: Counter +* Unit: `{message}` + +#### pulsar.broker.replication.message.backlog.age +The age of the oldest message in the replicator backlog. +* Type: Gauge +* Unit: `s` + +#### pulsar.broker.replication.message.expired.count +The total number of messages that expired for this replicator. +* Type: Counter +* Unit: `{message}` + +#### pulsar.broker.replication.message.dropped.count +The total number of messages dropped by this replicator. +* Type: Counter +* Unit: `{message}` + ### Schema Registry Metrics #### pulsar.broker.request.schema_registry.duration