pulsar

pulsar copied to clipboard

[Bug] Java Client : Pulsar Java client should be able to configure compression for message rejection in the DLQ

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version * Pulsar 3.0.1 * Java Client 3.0.1 ### Minimal reproduce step . Configure...

lgringo

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation pulsar version: 3.1.2 when I work with pulsar client and build by gradle,...

semistone

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version - producer 2.8.4 (java 11) - consumer 2.8.4, 2.8.1, 3.0.1 all failed (java...

Shawyeok

[fix][broker] Fix ResourceGroups loading

7

### Motivation When `org.apache.pulsar.broker.resourcegroup.ResourceGroupConfigListener#loadAllResourceGroups` is unfinished, the `org.apache.pulsar.broker.resourcegroup.ResourceGroupNamespaceConfigListener` will be created, which will bind the namespace and resource groups, but `loadAllResourceGroups` is async loading, so cause the `ResourceGroupNamespaceConfigListener` does not...

nodece

[fix][broker] Automatically create topic for remote cluster in geo

11

Fixes https://github.com/apache/pulsar/issues/21153 ### Motivation Enable the geo-replication only on the topic level to replicate the partitioned topic, if the topic was not created in the remote cluster, it becomes the...

nodece

[feat][monitor] PIP-222: Add PartitionMetadataRequest metrics

2

PIP: https://github.com/apache/pulsar/issues/18319 ### Motivation https://github.com/apache/pulsar/issues/18319 ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)*...

dao-jun

[feat][monitor] PIP-223: Add metrics for all rest endpoints.

6

PIP: https://github.com/apache/pulsar/issues/18560 ### Motivation https://github.com/apache/pulsar/issues/18560 ### Modifications ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please pick either of the following options)*...

dao-jun

### Motivation before:  after:  Change the query condition of prometheus from `kubernetes_pod_name` to `instance` ### Modifications ### Verifying this change - [ ] Make sure that the change...

XuQianJin-Stars

[feat] admin api/cli to delete package uploaded by pulsar-admin functions upload

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation There is `pulsar-admin functions upload` feature but no delete feature provided. So any...

truong-hua

[improve][functions] EFFECTIVELY_ONCE mode support input topic batching

1

Fixes #17061 Main Issue: #17061 ### Motivation The batch message will generate the same sequence ID in the function, which will cause a large amount of data in the batch...

graysonzeng