Yuri Mizushima

[client] Rename `test_helper.go` to follow the test code naming convention

2

### Motivation Package private functions and variables, defined in `pulsar/test_helper.go`, are called from test codes. However, it is recognized as a non-test code by Go Modules because it doesn't follow...

Add ensemble relocation command which adheres to placement policy

18

### Motivation Currently, we can't recover the ensemble which isn't adhering to placement policy directly. The `recover` command or autorecovery process is one of the alternative approaches. Unfortunately, however, we...

[fix][broker] Introduce the last sent position to fix message ordering issues in Key_Shared (PIP-282)

15

PIP: #20776 ### Motivation Key_Shared has a mechanism called the "recently joined consumers" to keep message ordering. However, currently, it doesn't care about some corner cases. More specifically, we found...

[fix][broker] Fix recentlyJoinedConsumers to address the out-of-order issue

6

### Motivation The Key_Shared subscription type has the following issues. 1. Key_Shared subscription has out-of-order cases because of the race condition of [the recently joined consumers feature](https://github.com/apache/pulsar/blob/35e9897742b7db4bd29349940075a819b2ad6999/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java#L400-L408). Consider the following...

Add new tenant operation LIST_ANTI_AFFINITY_NAMESPACES and fix validation of getAntiAffinityNamespaces

6

### Motivation Since https://github.com/apache/pulsar/pull/6428, we can define authz policy to each namespace operation. However, I think the operation policy `validateNamespacePolicyOperation(namespaceName, PolicyName.ANTI_AFFINITY, PolicyOperation.READ);` is not suitable for `getAntiAffinityNamespaces` method because this...

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