[pulsar] branch master updated (5b452d1ce82 -> b0945d1d45d)

[rd...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rdhabalia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 5b452d1ce82 [improve][doc] Add code example for WebSocket API to use TLS with CLI tools (#15485)
     add b0945d1d45d [feat] [broker] PIP-188 support blue-green cluster migration [part-1] (#17962)

No new revisions were added by this update.

Summary of changes:
 conf/broker.conf                                   |   4 +
 .../apache/bookkeeper/mledger/ManagedLedger.java   |   7 +
 .../bookkeeper/mledger/impl/ManagedLedgerImpl.java |  33 ++-
 .../apache/pulsar/broker/ServiceConfiguration.java |   7 +
 .../pulsar/broker/admin/impl/ClustersBase.java     |  62 ++++
 .../broker/service/AbstractBaseDispatcher.java     |  13 +
 .../pulsar/broker/service/AbstractTopic.java       |  31 +-
 .../pulsar/broker/service/BrokerService.java       |  11 +
 .../broker/service/BrokerServiceException.java     |  10 +
 .../org/apache/pulsar/broker/service/Consumer.java |  13 +
 .../org/apache/pulsar/broker/service/Producer.java |  11 +
 .../pulsar/broker/service/PulsarCommandSender.java |   3 +
 .../broker/service/PulsarCommandSenderImpl.java    |  13 +
 .../apache/pulsar/broker/service/ServerCnx.java    |  19 +-
 .../org/apache/pulsar/broker/service/Topic.java    |   2 +
 .../service/nonpersistent/NonPersistentTopic.java  |  40 ++-
 .../service/persistent/CompactorSubscription.java  |   4 +-
 .../PersistentDispatcherMultipleConsumers.java     |   2 +-
 .../PersistentDispatcherSingleActiveConsumer.java  |   2 +-
 ...istentStreamingDispatcherMultipleConsumers.java |   3 +-
 ...entStreamingDispatcherSingleActiveConsumer.java |   2 +-
 .../service/persistent/PersistentSubscription.java |   5 +-
 .../broker/service/persistent/PersistentTopic.java |  23 +-
 .../broker/intercept/CounterBrokerInterceptor.java |   2 +-
 .../broker/service/ClusterMigrationTest.java       | 329 +++++++++++++++++++++
 pulsar-client-admin-api/pom.xml                    |   1 +
 .../org/apache/pulsar/client/admin/Clusters.java   |  37 +++
 .../pulsar/common/policies/data/ClusterData.java   |  23 ++
 .../pulsar/client/admin/internal/ClustersImpl.java |  14 +
 .../pulsar/client/api/PulsarClientException.java   |  16 +
 .../org/apache/pulsar/admin/cli/CmdClusters.java   |  24 ++
 .../org/apache/pulsar/client/impl/ClientCnx.java   |  23 ++
 .../pulsar/client/impl/ConnectionHandler.java      |   7 +-
 .../apache/pulsar/client/impl/HandlerState.java    |   9 +
 pulsar-common/pom.xml                              |   5 +
 .../common/policies/data/ClusterDataImpl.java      |  27 +-
 .../apache/pulsar/common/protocol/Commands.java    |  11 +
 .../pulsar/common/protocol/PulsarDecoder.java      |  10 +
 pulsar-common/src/main/proto/PulsarApi.proto       |  17 ++
 site2/docs/reference-pulsar-admin.md               |  18 ++
 .../offload/jcloud/impl/MockManagedLedger.java     |  12 +
 41 files changed, 886 insertions(+), 19 deletions(-)
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ClusterMigrationTest.java