Tao Jiuming

[pulsar][receiver] add apache pulsar receiver

5

issue: https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/9796 support apache pulsar as opentelemetry-collector receiver

[enh] Make maxAccumulations configurable and add remove method for meters

2

Motivation: 1. Currently, a meter(COUNTER/GAUGE/HISTOGRAM, etc.) could only have 2000 children, which means it couldn't cover some situations (such as there are 10000 topics in a broker, and they all...

[fix][flaky-test] fix PersistentStreamingDispatcherBlockConsumerTest.testBrokerSubscriptionRecovery

1

Fixes https://github.com/apache/pulsar/issues/17011 ### Motivation Fix https://github.com/apache/pulsar/issues/17011 ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update...

[broker][monitoring] add per-subscription EntryFilter metrics

1

Fixes https://github.com/apache/pulsar/issues/16596 ### Motivation add per-subscription `EntryFilter` metrics for PersistentTopic and NonPersistentTopic. ### Modifications Add the following metrics to Prometheus: 1. pulsar_subscription_through_filter_msg_count 2. pulsar_subscription_filter_accepted_msg_count 3. pulsar_subscription_filter_rejected_msg_count 4. pulsar_subscription_filter_rescheduled_msg_count Add the...

[monitor][txn] Add metrics for transaction

19

### Motivation add metrics for transaction ### Does this pull request potentially affect one of the following parts: *If `yes` was chosen, please highlight the changes* - Dependencies (does it...

[fix][ml] fix NPE

6

Fixes [#16907](https://github.com/apache/pulsar/issues/16907) ### Motivation Fixes [#16907](https://github.com/apache/pulsar/issues/16907) ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ] `doc-required` (Your PR needs to update...

Add MetricsFormatter to allow develops could collect metrics by their own way.

30

Add MetricsFormatter to allow develops collect metrics by their own way. For more context, you can see https://github.com/prometheus/client_java/pull/782

[enh][pulsar] add apache pulsar semantic_conventions

4

## Changes add apache pulsar semantic_conventions. Related issues # Related [OTEP(s)](https://github.com/open-telemetry/oteps) #

offloader metrics dashboard

1

MovitItion This pr is based on https://github.com/apache/pulsar/pull/13833, show offload metrics. 

[feat][offload] Support namespace/topic level auto trigger offload policy.

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, Pulsar only supports global offload auto trigger policy: `managedLedgerOffloadAutoTriggerSizeThresholdBytes` and `managedLedgerOffloadTimeThresholdInSeconds`(see: https://github.com/apache/pulsar/pull/17398),...