Zac Bentley

QoL improvement: MaxReconnectToBroker and BackoffPolicy UX improvements

1

**Is your feature request related to a problem? Please describe.** Usability problems: - MaxReconnectToBroker is a `*uint` for what seems to be no good reason. Pointers to primitive ints are...

max_total_receiver_queue_size_across_partitions does not work

10

**Describe the bug** The `max_total_receiver_queue_size_across_partitions` kwarg to the Python `subscribe` method is nonfunctional. **To Reproduce** 1. Create a persistent partitioned topic. I used 4 partitions. 2. Create a `Shared` subscription...

Client is highly fork-unsafe: any usage of multiprocessing deadlocks if an at-fork hook triggers garbage collection of a Pulsar client

10

## Context: - Pulsar 2.10.2 (StreamNative) - Pulsar client Python 2.10.1 and 3.1.0 both repro'd. - Python 3.10 and 3.7 - Linux (Ubuntu 20) and MacOS. ## Bug description: It's...

[python client] message properties are not round-trippable

3

**Describe the bug** Properties objects on messages can be set to (and published with) values that cannot be deserialized on the far side. **To Reproduce** 1. Using the Python client,...

On partitioned topics with the Python client, receiver_queue_size=0 results in an InvalidConfiguration error, but is documented to work

16

**Describe the bug** Passing `receiver_queue_size=0` to the Python client's `subscribe` method results in a `InvalidConfiguration` exception. However, [these docs](https://pulsar.apache.org/docs/cookbooks-message-queue/) indicate that a receiver queue size of 0 is supported. **To...

Disposing of a Python Consumer object without calling close() leaks file descriptors and does not close the consumer.

3

**Describe the bug** If a Python pulsar-client Consumer object is destroyed (garbage collected) without its `close()` method being called, the consumer remains connected, and its file descriptors remain open. **To...

[2.8.0] Python client instances emit logs for every client instance ever constructed with a `logger` argument

9

**Describe the bug** When `Client` instances are constructed with the Python driver, they seem to accumulate the value of the `logger` argument as global state. This means two things: 1....

Attempting to connect a consumer to a very recently created topic/subscription sometimes fails with UnknownError on the client

4

**Describe the bug** If I create a topic/subscription via the management API and then immediately attempt to connect a consumer to that subscription via the C++ client, the `subscribe` call...

Four changes in this PR: 1. Allow `rm_watch` to take a PathLike or a descriptor number. `add_watch` now tracks created watches internally, and `rm_watch` uses and updates that tracker. `close()`...

This PR contains a few miscellaneous improvements; I'm happy to break it up into separate PRs if that's undesirable. Contents: 1. Attempt to make `read()` thread-safe (as in, it will...