This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5668058 Getting the stats of a non-persistent topic that has been
cleaned causes it to re-appear (#9029)
new 4c2cded Fix idea warning (#8588)
new 897203d Fixes the recovery not respect to the isolation group
settings (#8961)
The 2 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:
.../mledger/impl/LedgerMetadataUtils.java | 22 +++++
.../mledger/impl/ManagedLedgerFactoryImpl.java | 39 +-------
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 24 ++++-
.../bookkeeper/mledger/offload/OffloadUtils.java | 1 -
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 21 ++++-
.../broker/authentication/PulsarSaslServer.java | 1 -
.../broker/cache/ConfigurationCacheService.java | 1 -
.../apache/pulsar/PulsarClusterMetadataSetup.java | 2 +-
.../pulsar/broker/ManagedLedgerClientFactory.java | 2 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 4 +-
.../pulsar/common/naming/NamespaceBundles.java | 2 +-
.../broker/service/BrokerBookieIsolationTest.java | 2 +-
.../org/apache/pulsar/client/cli/CmdProduce.java | 1 -
.../pulsar/client/impl/UnAckedMessageTracker.java | 1 -
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 1 -
.../client/impl/auth/AuthenticationDataTls.java | 3 -
.../pulsar/client/impl/auth/AuthenticationTls.java | 1 -
.../client/impl/transaction/TransactionImpl.java | 2 -
pulsar-common/pom.xml | 5 +
.../data/EnsemblePlacementPolicyConfig.java | 76 ++++++++++++++++
.../runtime/kubernetes/KubernetesRuntime.java | 2 +-
.../pulsar/functions/worker/WorkerConfig.java | 1 -
.../pulsar/functions/utils/ValidatorUtils.java | 4 -
.../utils/functioncache/FunctionCacheEntry.java | 3 -
.../pulsar/functions/worker/MembershipManager.java | 7 --
.../pulsar/functions/worker/SchedulerManager.java | 2 +-
.../metadata/impl/zookeeper/ZKMetadataStore.java | 1 -
.../apache/pulsar/proxy/server/ProxyService.java | 2 +-
.../pulsar/zookeeper/GlobalZooKeeperCache.java | 1 -
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 2 +-
.../pulsar/zookeeper/LocalZooKeeperCache.java | 1 -
.../zookeeper/LocalZooKeeperConnectionService.java | 5 +-
.../ZkIsolatedBookieEnsemblePlacementPolicy.java | 101 +++++++++++++++++----
.../java/org/apache/pulsar/zookeeper/ZkUtils.java | 8 +-
.../apache/pulsar/zookeeper/ZooKeeperCache.java | 6 +-
.../pulsar/zookeeper/ZooKeeperChildrenCache.java | 1 -
.../pulsar/zookeeper/ZooKeeperSessionWatcher.java | 1 +
...kIsolatedBookieEnsemblePlacementPolicyTest.java | 65 +++++++++++++
38 files changed, 320 insertions(+), 104 deletions(-)
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/EnsemblePlacementPolicyConfig.java
