pulsar

pulsar copied to clipboard

fix connect zookeeper slow for getHostName fail

3

### Motivation I met same issue with #14578, broker cannot start due to fail to connect to zookeeper with ConnectionLoss error, and zookeeper shell can connect but cost about 20s...

wangjialing218

[fix][broker] fix ns total size stats

13

*(If this PR fixes a github issue, please add `Fixes #`.)* Fixes #15492 *(or if this PR is one task of a github issue, please add `Master Issue: #` to...

leizhiyuan

[fix] [broker] Disabled deduplication, but ledger-store will not be d…

13

### Motivation When execute command `ulsar-admin topicPolicies get-deduplication persistent://{tenant}/{ns}/{topic}` failure. Then the `deduplication task` will be disabled, and cursor 'pulsar.dedup' will not move still restart `broker`. But zk-node: `/managed-ledgers/{tenant}/{ns}/persistent/{topic}/pulsar.dedup` still...

poorbarcode

[Function] support storageClient backoffPlicy configure

2

### Motivation When create StorageClient, will use backoffPolicy, but the parameter inside is hardcoded, especially when using localrun mode, if the network delay is large, you need to adjust this...

liudezhi2098

[fix] [client] NotifyPendingReceivedCallback when zeroConsumerImpl received batch message firstly then close consumer

11

### Motivation NotifyPendingReceivedCallback when zeroConsumerImpl received batch messsage firstly , then close consumer. ### Documentation - [x] `doc-not-needed`

horizonzy

[pulsar-broker] Fix delete empty namespace with partitioned-topic metadata

7

### Motivation Right now, broker gives below error while deleting empty namespace without any topic under the namespace but namespace was having partitioned-topic metadata. ``` pulsar-admin namespaces delete prop/us-west/my-ns Cannot...

rdhabalia

[websocket] Replace blocking logic to avoid OOM

1

### Motivation I encountered an OOM issue in pulsar-websocket because users do negative ack very frequently for mistaken. For the heap dump, many `org.apache.pulsar.websocket.ConsumerHandler$1` are referenced from ConsumerHandler. https://github.com/apache/pulsar/blob/acac76e9799bc31e388c593aa553711c6ad734aa/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java#L169-L187 ###...

equanz

[fix][broker] The offline consumer is not removed from the consumerList

9

### Motivation **We found a problem: when the consumer was removed, it was not removed from the consumerList, but it was removed from the consumerSet and consumers：** **The log to...

lordcheng10

[fix][broker] Fix ArrayIndexOutOfBoundsException due to race condition

14

### Motivation ``` WARN ] 2022-03-10 17:27:26.976 [pulsar-io-36-20] ServerCnx - [/127.0.0.1:55561] Got exception java.lang.ArrayIndexOutOfBoundsException: 1 at java.util.concurrent.CopyOnWriteArrayList.get(CopyOnWriteArrayList.java:388) at java.util.concurrent.CopyOnWriteArrayList.get(CopyOnWriteArrayList.java:397) at org.apache.pulsar.broker.service.AbstractDispatcherMultipleConsumers.getNextConsumer(AbstractDispatcherMultipleConsumers.java:121) at org.apache.pulsar.broker.service.nonpersistent.NonPersistentDispatcherMultipleConsumers.sendMessages(NonPersistentDispatcherMultipleConsumers.java:192) at org.apache.pulsar.broker.service.nonpersistent.NonPersistentTopic.lambda$publishMessage$1(NonPersistentTopic.java:182) at org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap$Section.forEach(ConcurrentOpenHashMap.java:387) at org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap.forEach(ConcurrentOpenHashMap.java:159) at...

leizhiyuan

Ignoring flow control message when resetCursorInProgress=TRUE

5

Fixes #14559 Master Issue: #14559 ### Motivation When cursor is in the `seek` process, re-subscribed `flow` requests should be ignored. - [x] `no-need-doc`

wenbingshen