pulsar

pulsar copied to clipboard

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes....

gaozhangmin

[improve][broker] Deny removing local cluster from topic level replicated cluster policy

2

### Motivation - When a topic detects that its cluster policies do not contain the local cluster, the topic will delete itself. - This mechanism is designed for the following...

poorbarcode

[fix][ml]Received more than once callback when calling cursor.delete

2

### Motivation **About cursor deleting, there are two cases** - `scenario-A`: Acked nothing, because all positions have been acknowledged before. - `scenario-B`: Acked some position, then it will try to...

poorbarcode

[fix][client] Client interceptors close method not called after producer/consumer/reader close

1

### Motivation The `close` methods in client interceptors (`ProducerInterceptor#close`, `ConsumerInterceptor#close`, `ReaderInterceptor#close`) allow interceptor developers to release resources allocated in the interceptor when a producer, consumer, or reader is closed. However,...

Shawyeok

### Motivation This PR addresses a potential NullPointerException (NPE) that could occur when calling the `seek()` method with a `TopicMessageIdImpl` that has a null topic. ### Modifications 1. Added null...

3pacccccc

[feat][pip] PIP-420: Provide ability for Pulsar clients to integrate with third-party schema registry service

2

### Motivation The Pulsar client is better has the ability to access third-party schema registry service to manage the schema (register schema, get schema, validate schema, etc.). The schema registry...

gaoran10

[fix] Don't use ForkJoinPool when using CompletableFuture.thenXXXAsync

8

### Motivation Currently, in some cases when don't pass an executor to `CompletableFuture`.`thenComposeAsync/thenApplyAsync/thenAcceptAsync`, which will use `ForkJoinPool.commonPool`. Which maybe lead to 3 problems: 1. `ForkJoinPool.commonPool` is managed by JVM, it...

dao-jun

### Motivation When the Prometheus library versions differ between the broker and the bookkeeper, it may cause compatibility issues that prevent us from retrieving metrics from the bookie. ### Modifications...

nodece

[improve][pip] PIP-425: Support connecting with next available endpoint for multi-endpoint serviceUrls

4

Fixes https://github.com/apache/pulsar/issues/22934#issuecomment-2943690398 Main Issue: https://github.com/apache/pulsar/issues/22934#issuecomment-2943690398 Implementation: https://github.com/apache/pulsar/pull/24387 ### Motivation As https://github.com/apache/pulsar/issues/22934 and https://github.com/apache/pulsar/discussions/22933 mentioned, when most of the nodes in serviceurl are down (but there is at least one available...

AuroraTwinkle

[fix] [broker] Fix negative subscription/consumer's unack-messages

2

### Motivation **Issue**: negative unack-messages - Consumer-1 received messages. - Unload the topic. - The message may be sent to consumer-2, but the consumption of consumer-1 is still in progress...

poorbarcode