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....

TakaHiR07

Flaky-test: BrokerRegistryMetadataStoreIntegrationTest.cleanup

1

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/actions/runs/18802878674/job/53653078467#step:11:676 ### Exception stacktrace ```text [ERROR] org.apache.pulsar.broker.loadbalance.extensions.BrokerRegistryMetadataStoreIntegrationTest.cleanup -- Time elapsed: 11.19 s

lhotari

[improve][broker] Improve the performance of TopicName

10

### Motivation The `TopicName`'s constructor has poor performance: - `NamespaceName#get` is very slow - `Splitter.on("/").splitToList(rest)` is slow - `String.format` is slower than the `+` operation on strings and `completeTopicName` is...

BewareMyPower

### 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

[fix][broker]V1 topic creation should fail if namespace does not exist

1

### Motivation V1 topic creation is allowed even if the namespace does not exist. After a topic creation, users will get the following concerns - users will get a namespace...

poorbarcode

[fix][sec] Update reactor-netty-http in Azure Data Explorer connector to remediate CVE-2025-22227

2

Fixes #xyz Main Issue: #xyz PIP: #xyz ### Motivation This PR removes the transitive dependency reactor-netty-http from the Azure Data Explorer module. The module was bringing in io.projectreactor.netty classes that...

guptas6est

### Motivation In geo, the `msgOut` is inaccurate: 1. When `Entry` is batch message, the `org.apache.pulsar.common.stats.Rate#countAdder` and `org.apache.pulsar.common.stats.Rate#totalCountAdder` increment only once. 2. When the network fails, the `org.apache.pulsar.common.stats.Rate#recordEvent(long)` shouldn't be...

nodece

[fix][broker] Fix NamespaceService#getListOfNonPersistentTopics not found the topic

2

### Motivation When using the admin-client to set the replication cluster for non-persistent partitioned topic, the broker throws the topic not found, due to `org.apache.pulsar.broker.namespace.NamespaceService#getListOfNonPersistentTopics` didn't fetch the non-persistent partitioned...

nodece

[fix][broker]Can't consume messages for a long time due to Entry Filter

4

Fixes: - https://github.com/apache/pulsar/issues/16978 ### Motivation When there are two consumers, users can specify the consumption behavior of each consumer by `Entry filter`: - `case`: `consumer_1` can consume 60% of the...

poorbarcode

[fix][broker] ClassCastException when specify flow_or_qps_equally_div…

4

splitAlgorithm is alreay specified by user or default before input to this method. It will initial wrong option type and throw ClassCastException when user specified FlowOrQpsEquallyDivideBundleSplitAlgorithm and default is not....

zhangqian321