pulsar

pulsar copied to clipboard

[improve][broker] Skip auto-creation for topics with "-partition-" suffix missing a valid partition number

4

### Motivation If you actively create a topic with "-partition--x" (x is an integer)(for example, "peisisten://tenant-name/ns-name/topic-name-partition--1"), the topic can be created successfully, and a node with partition 3 will be...

zjxxzjwang

Incorrect msgBacklog value

9

**Describe the bug** Despite there are no messages in the backlog, positive value was set to "msgBacklog" in the response of partitioned-stats(API). I think "msgBacklog" is calculated from "ManagedLedgerImpl.ENTRIES_ADDED_COUNTER_UPDATER" and...

shustsud

[Bug] can not create topic due to failure of initialization of policies even the namespace is re-created

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version 2.11.3 ### Minimal reproduce step I have no exact reproduce steps but my...

truong-hua

Flaky-test: PulsarWorkerRebalanceDrainTest.testRebalanceWorkers. Function worker leader changes unpredictably causing flakiness.

1

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://gist.github.com/ShivrajJ/134d23d79a6e122677fd5b300c4de3fa ### Exception stacktrace I added a debug-level log with the topic...

ShivrajJ

[Geo-replication] Subscription replication is not working across clusters

26

**Describe the bug** I'm testing geo-replication with subscription enabled. In my testing environment, there are 2 clusters (ClusterA and ClusterB) with a global zookeeper on a dedicated server host. Each...

yabinmeng

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://gist.github.com/storm-08/61ff3104a1f0492cfa98c600708faa3e ### Exception stacktrace Please note I have added Thread.sleep(5) in my...

storm-08

### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, the Debezium connector is set to [Debezium version 1.9.7](https://github.com/apache/pulsar/blame/branch-4.0/pom.xml#L241-L242), last updated November...

peisenmann

[fix][ml] Cancel Metadata Store listeners at shutdown to fix resource leaks in some tests

1

### Motivation The current MetadataStore API and MetadataStoreExtended API doesn't provide a way to cancel (unregister) registered listeners. This is a problem in some tests where the metadata store instance...

lhotari

[fix][broker] pattern regex error in PulsarLedgerManager cause zk data notification can not execute

7

### Motivation ledger zk path is like "/ledgers/00/0601/L7170". But currently it exist pattern regex error cause zk data notification can not execute. ledgerPathRegex.matcher(n.getPath()).matches() is always false.  ### Modifications use...

TakaHiR07

[improve][broker] Don't call ManagedLedger#asyncAddEntry in Netty I/O thread

2

### Motivation https://github.com/apache/pulsar/pull/23940 brings a behavior change that the core logic of `ManagedLedger#asyncAddEntry` now won't switch threads, which means it will be executed directly in Netty I/O thread via `PersistentTopic#asyncAddEntry`....

BewareMyPower