You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by wa...@apache.org on 2022/03/15 16:04:59 UTC
[pulsar] 03/13: Merge branch 'master' of https://github.com/apache/pulsar
This is an automated email from the ASF dual-hosted git repository.
wave pushed a commit to branch dave2wave-branch-14693
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 6aeb408adacf53947ec708b6a0d2ac380d75f62b
Merge: 9aa943b 3df9018
Author: Dave Fisher <da...@datastax.com>
AuthorDate: Mon Jan 31 08:36:00 2022 -0800
Merge branch 'master' of https://github.com/apache/pulsar
conf/functions_worker.yml | 11 +-
deployment/terraform-ansible/aws/ansible.cfg | 2 +-
deployment/terraform-ansible/aws/instances.tf | 56 ++--
deployment/terraform-ansible/aws/keys.tf | 4 +-
deployment/terraform-ansible/aws/network.tf | 50 +--
deployment/terraform-ansible/aws/provider.tf | 3 +-
deployment/terraform-ansible/aws/security.tf | 8 +-
deployment/terraform-ansible/aws/setup-disk.yaml | 14 +-
deployment/terraform-ansible/aws/terraform.tfvars | 4 +-
deployment/terraform-ansible/aws/variables.tf | 2 +-
.../aws/{provider.tf => versions.tf} | 14 +-
deployment/terraform-ansible/deploy-pulsar.yaml | 4 +-
.../bookkeeper/mledger/ManagedLedgerConfig.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 12 +-
.../mledger/impl/NullLedgerOffloader.java | 2 +-
.../apache/bookkeeper/mledger/util/Futures.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 10 +-
.../org/apache/pulsar/broker/PulsarService.java | 4 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 6 +-
.../pulsar/broker/service/AbstractTopic.java | 6 +
.../pulsar/broker/service/BrokerService.java | 2 +-
.../org/apache/pulsar/broker/service/Consumer.java | 37 ++-
.../apache/pulsar/broker/service/ServerCnx.java | 23 +-
...istentStickyKeyDispatcherMultipleConsumers.java | 1 +
.../broker/service/persistent/PersistentTopic.java | 18 +-
.../pulsar/broker/web/PulsarWebResource.java | 85 +++--
.../BatchMessageWithBatchIndexLevelTest.java | 68 ++++
.../client/api/KeySharedSubscriptionTest.java | 128 +++++++
.../client/impl/TransactionEndToEndTest.java | 70 +++-
.../client/api/AutoClusterFailoverBuilder.java | 128 +++++++
.../api/ControlledClusterFailoverBuilder.java | 73 ++++
.../pulsar/client/api/ServiceUrlProvider.java | 10 +-
.../TransactionCoordinatorClientException.java | 15 -
pulsar-client-cpp/docker-build-centos7.sh | 2 +-
pulsar-client-cpp/docker/centos-7/Dockerfile | 7 +
pulsar-client-cpp/tests/ConsumerTest.cc | 2 +-
.../pulsar/client/impl/AutoClusterFailover.java | 368 +++++++++++++++++++++
.../client/impl/ControlledClusterFailover.java | 270 +++++++++++++++
.../pulsar/client/impl/PulsarClientImpl.java | 28 ++
.../oauth2/protocol/DefaultMetadataResolver.java | 6 +
.../pulsar/client/impl/schema/AvroSchema.java | 9 +-
.../pulsar/client/impl/schema/util/SchemaUtil.java | 2 +-
.../client/impl/AutoClusterFailoverTest.java | 248 ++++++++++++++
.../client/impl/ControlledClusterFailoverTest.java | 130 ++++++++
.../pulsar/client/impl/schema/AvroSchemaTest.java | 23 +-
.../policies/data/HierarchyTopicPolicies.java | 2 +
.../pulsar/functions/worker/WorkerConfig.java | 16 +
.../org/apache/pulsar/functions/worker/Worker.java | 3 +-
.../pulsar/proxy/server/ProxyConfiguration.java | 14 +
.../apache/pulsar/proxy/server/ProxyService.java | 10 +-
.../pulsar/sql/presto/PulsarConnectorCache.java | 2 +-
site2/docs/client-libraries-java.md | 39 ++-
site2/docs/concepts-architecture-overview.md | 3 +
site2/docs/functions-runtime.md | 2 +-
site2/docs/functions-worker.md | 4 +-
site2/docs/getting-started-standalone.md | 6 +-
site2/docs/reference-configuration.md | 4 +-
site2/docs/schema-evolution-compatibility.md | 2 +-
site2/docs/schema-manage.md | 119 ++++++-
site2/website-next/docs/functions-runtime.md | 2 +-
site2/website-next/docs/functions-worker.md | 4 +-
61 files changed, 1985 insertions(+), 216 deletions(-)