grayson

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation In [PIP-121](https://github.com/apache/pulsar/issues/13315)，we support cluster level controlled cluster failover on client side。But I have...

Make netty acceptor threadPool size configurable

1

Descriptions of the changes in this PR: default value of acceptor threadPool is 2*cpu core, it is unnecessary and not separate configuration。 ### Motivation Make Netty acceptor threads separate configurable...

[fix][Offload] fix indexEntries NullPointerException error

4

### Motivation Offloader exception occurs ``` 21:54:32.360 [offloader-OrderedScheduler-14-0] ERROR org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - Unknown exception for ManagedLedgerException. org.apache.bookkeeper.mledger.ManagedLedgerException$OffloadReadHandleClosedException: Offload read handle already closed 21:54:32.424 [offloader-OrderedScheduler-14-0] WARN org.apache.bookkeeper.common.util.SingleThreadSafeScheduledExecutorService - Unexpected throwable from task...

[Bug] Cannot determine whether the message is a duplicate at this time

3

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version pulsar version：3.1.1，master ### Minimal reproduce step broker count: 2 bookie count: 5 broker...

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

[fix][client] Fix race conditions of LedgerHandle in client

32

Master Issue: https://github.com/apache/pulsar/issues/21860 ### Motivation When bookies do a rolling restart, pulsar topic fence state may be triggered due to race conditions. And it can not recover. After check the...

**BUG REPORT** ***Describe the bug*** `2023-11-25T14:29:27,343+0800 [BookieReadThreadPool-OrderedExecutor-5-0] ERROR org.apache.bookkeeper.server.service.BookieService - Unable to allocate memory, exiting bookie io.netty.util.internal.OutOfDirectMemoryError: failed to allocate 8392704 byte(s) of direct memory (used: 15024140317, max: 15032385536)` ***To...

[issue] In effectively_once mode, when a single pod fails, the entire function will fail due to failure to create the producer.

15

1. When I enable effectively_once and deploy the function in k8s, for example, after deploying 5 pods, when one of my pods crashes, his subscription will be transferred to other...

[feature][proxy] Add clientStats API for ProxyStats

1

Master Issue: https://github.com/apache/pulsar/issues/17625 ### Motivation Add a new api named clientStats to proxy stats ### Modifications see issue ### Verifying this change - [x] Make sure that the change passes...

## Enhancement ### Description For long time running sql queries, hope the progress can be queried through queryid for user easy to use. One suggestion is to use the FinishedFragmentNums/TotalFragmentNums...