url: https://github.com/apache/pulsar/issues/20772 --- ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation When I want to monitor the relevant data in the `BrokerInterceptor`, currently the `BrokerInterceptor` does not provide relevant interfaces. I think providing such extensions is necessary. ### Solution https://github.com/apache/pulsar/blob/e96b3398912163eb6e0528c10aed3507c95952fd/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java Add a interface, like this: ```java default void addCustomizeMetrics(PrometheusMetricStreams streams, PulsarService pulsar){ } ``` https://github.com/apache/pulsar/blob/e96b3398912163eb6e0528c10aed3507c95952fd/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java#L185-L187 Then callback the `addCustomizeMetrics(stream, pulsar)` method here. This is just a draft. ### Alternatives _No response_ ### Anything else? _No response_ ### Are you willing to submit a PR? - [X] I'm willing to submit a PR!
url: apache#20772
Search before asking
Motivation
When I want to monitor the relevant data in the
BrokerInterceptor, currently theBrokerInterceptordoes not provide relevant interfaces.I think providing such extensions is necessary.
Solution
https://github.com/apache/pulsar/blob/e96b3398912163eb6e0528c10aed3507c95952fd/pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java
Add a interface, like this:
https://github.com/apache/pulsar/blob/e96b3398912163eb6e0528c10aed3507c95952fd/pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java#L185-L187
Then callback the
addCustomizeMetrics(stream, pulsar)method here.This is just a draft.
Alternatives
No response
Anything else?
No response
Are you willing to submit a PR?