This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from d4aa14de755 [fix][sec] Upgrade Avro to 1.11.4 to address
CVE-2024-47561 (#23394)
new 63ca5ecb9e1 [fix] [log] Do not print error log if tenant/namespace
does not exist when calling get topic metadata (#23291)
new 25feaf791ed [fix][broker] Fix the broker registery cannot recover from
the metadata node deletion (#23359)
new 57304ed1706 [fix][misc] Log Conscrypt security provider initialization
warnings at debug level (#23364)
new bc578e07cad [improve] Install openssl in the docker image to fix
compatibility with Apache Pulsar Helm chart (#23362)
new 8b47a528ded [improve][build] Use amazoncorretto:21-alpine image
instead of apk installation (#22973)
new d0ab26e3bef [improve][ci] Switch to Java 21 as default JVM version for
CI (#23373)
new caf214e70ec [improve] Upgrade Pulsar Python client in docker image to
3.5.0 (#23377)
new 0c6abe0f323 [fix][broker] Cancel possible pending replay read in
cancelPendingRead (#23384)
new 43aabfc7209 [fix][broker] Fix out-of-order issues with
ConsistentHashingStickyKeyConsumerSelector (#23327)
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/pulsar-ci.yaml | 14 +-
bin/function-localrunner | 9 +-
conf/bkenv.sh | 14 +-
conf/pulsar_env.sh | 13 +-
docker/pulsar/Dockerfile | 10 +-
docker/pulsar/pom.xml | 1 +
pom.xml | 30 +-
.../loadbalance/extensions/BrokerRegistry.java | 6 +-
.../loadbalance/extensions/BrokerRegistryImpl.java | 57 ++--
...ConsistentHashingStickyKeyConsumerSelector.java | 104 +++---
.../broker/service/ConsumerIdentityWrapper.java | 70 ++++
.../broker/service/ConsumerNameIndexTracker.java | 136 ++++++++
.../apache/pulsar/broker/service/ServerCnx.java | 41 ++-
.../PersistentDispatcherMultipleConsumers.java | 3 +-
.../broker/admin/GetPartitionMetadataTest.java | 51 +++
.../extensions/BrokerRegistryIntegrationTest.java | 124 +++++++
.../loadbalance/extensions/BrokerRegistryTest.java | 6 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 2 +-
...istentHashingStickyKeyConsumerSelectorTest.java | 366 ++++++++++++++++++++-
.../service/ConsumerIdentityWrapperTest.java | 68 ++++
.../service/ConsumerNameIndexTrackerTest.java | 157 +++++++++
...ntStickyKeyDispatcherMultipleConsumersTest.java | 9 +-
.../java/org/apache/pulsar/client/api/Range.java | 11 +-
.../apache/pulsar/common/util/SecurityUtility.java | 8 +-
24 files changed, 1155 insertions(+), 155 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerIdentityWrapper.java
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerNameIndexTracker.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerIdentityWrapperTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ConsumerNameIndexTrackerTest.java
