This is an automated email from the ASF dual-hosted git repository.
liuyu pushed a commit to branch fix-9401
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c5f9a897b217b19d030e984c60fe8d131c64dd88
Merge: a9b7dbce e4b4627
Author: Anonymitaet <anonymitaet_hotmail.com>
AuthorDate: Thu Mar 25 17:14:03 2021 +0800
Merge remote-tracking branch 'origin/master' into fix-9401
.github/workflows/ci-build-macos.yaml | 10 +-
.github/workflows/ci-cpp.yaml | 41 +-
.github/workflows/ci-go-functions-style.yaml | 28 +-
.github/workflows/ci-go-functions-test.yaml | 24 +-
.../ci-integration-backwards-compatibility.yaml | 47 +-
.github/workflows/ci-integration-cli.yaml | 47 +-
...ion-state.yaml => ci-integration-function.yaml} | 51 +-
.github/workflows/ci-integration-messaging.yaml | 47 +-
.github/workflows/ci-integration-process.yaml | 47 +-
.github/workflows/ci-integration-schema.yaml | 47 +-
.github/workflows/ci-integration-sql.yaml | 47 +-
.github/workflows/ci-integration-standalone.yaml | 47 +-
.github/workflows/ci-integration-thread.yaml | 47 +-
.../ci-integration-tiered-filesystem.yaml | 47 +-
.../workflows/ci-integration-tiered-jcloud.yaml | 47 +-
.github/workflows/ci-integration-transaction.yaml | 47 +-
.github/workflows/ci-license.yaml | 40 +-
.github/workflows/ci-maven-cache-update.yaml | 114 +
.github/workflows/ci-pulsar-website-build.yaml | 19 +
.github/workflows/ci-pulsarbot.yaml | 3 -
.github/workflows/ci-shade-test.yaml | 47 +-
.github/workflows/ci-unit-broker-broker-gp1.yaml | 45 +-
.github/workflows/ci-unit-broker-broker-gp2.yaml | 44 +-
.github/workflows/ci-unit-broker-client-api.yaml | 45 +-
.github/workflows/ci-unit-broker-client-impl.yaml | 45 +-
.github/workflows/ci-unit-broker-other.yaml | 48 +-
.github/workflows/ci-unit-proxy.yaml | 44 +-
.github/workflows/ci-unit.yaml | 42 +-
bin/pulsar | 5 +-
.../retry_integration.sh | 42 +-
build/run_integration_group.sh | 12 +-
build/run_unit_group.sh | 117 +-
.../apache/pulsar/tests/AnnotationListener.java | 6 +-
.../apache/pulsar/tests/PulsarTestListener.java | 4 +-
.../org/apache/pulsar/tests/RetryAnalyzer.java | 2 +-
.../org/apache/pulsar/tests/TestRetrySupport.java | 4 +-
.../org/apache/pulsar/tests/ThreadDumpUtil.java | 2 +-
conf/broker.conf | 6 +-
conf/presto/catalog/pulsar.properties | 3 +
conf/standalone.conf | 2 +-
conf/zookeeper.conf | 19 +-
deployment/terraform-ansible/templates/broker.conf | 4 +-
distribution/server/src/assemble/LICENSE.bin.txt | 8 +-
docker/pulsar/scripts/gen-yml-from-env.py | 15 +
.../bookkeeper/mledger/impl/EntryCacheImpl.java | 6 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 2 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 -
.../ManagedLedgerFactoryChangeLedgerPathTest.java | 36 +
.../bookkeeper/test/MockedBookKeeperTestCase.java | 22 +-
pom.xml | 30 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 7 +
.../AuthenticationProviderToken.java | 10 +-
.../resources/LoadManagerReportResources.java | 13 +-
.../broker/resources/MetadataStoreCacheLoader.java | 100 +-
.../pulsar/broker/resources/PulsarResources.java | 2 +
pulsar-broker-shaded/pom.xml | 48 +
.../org/apache/pulsar/PulsarVersionStarter.java} | 13 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 11 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 18 +-
.../apache/pulsar/broker/admin/v1/Namespaces.java | 2 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 16 +-
.../apache/pulsar/broker/service/PulsarStats.java | 20 +
.../apache/pulsar/broker/service/ServerCnx.java | 13 +
...istentStickyKeyDispatcherMultipleConsumers.java | 2 +-
.../broker/service/persistent/PersistentTopic.java | 17 +-
.../streamingdispatch/StreamingEntryReader.java | 4 +-
.../broker/stats/BrokerOperabilityMetrics.java | 58 +-
.../prometheus/PrometheusMetricsGenerator.java | 5 +
.../buffer/impl/TopicTransactionBuffer.java | 19 +-
.../pulsar/broker/web/PulsarWebResource.java | 14 +-
.../pulsar/common/naming/NamespaceBundle.java | 8 +-
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 6 +-
.../broker/BookKeeperClientFactoryImplTest.java | 1 +
.../apache/pulsar/broker/SLAMonitoringTest.java | 24 +-
.../broker/admin/AdminApiDelayedDelivery.java | 2 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 1 +
.../broker/admin/AdminApiMaxUnackedMessages.java | 1 +
.../pulsar/broker/admin/AdminApiOffloadTest.java | 3 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 1 +
.../pulsar/broker/admin/AdminApiSchemaTest.java | 4 +-
.../admin/AdminApiSchemaValidationEnforced.java | 1 +
.../apache/pulsar/broker/admin/AdminApiTest.java | 24 +-
.../apache/pulsar/broker/admin/AdminApiTest2.java | 133 +-
.../pulsar/broker/admin/AdminApiTlsAuthTest.java | 1 +
.../pulsar/broker/admin/AdminResourceTest.java | 1 +
.../org/apache/pulsar/broker/admin/AdminTest.java | 3 +-
.../pulsar/broker/admin/AdminTopicApiTest.java | 2 +-
.../apache/pulsar/broker/admin/BookiesApiTest.java | 10 +-
.../broker/admin/BrokerAdminClientTlsAuthTest.java | 1 +
.../broker/admin/CreateSubscriptionTest.java | 1 +
.../broker/admin/IncrementPartitionsTest.java | 1 +
.../broker/admin/MaxUnackedMessagesTest.java | 1 +
.../apache/pulsar/broker/admin/NamespacesTest.java | 8 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 1 +
.../pulsar/broker/admin/TopicAutoCreationTest.java | 1 +
.../pulsar/broker/admin/TopicMessageTTLTest.java | 1 +
.../broker/admin/TopicPoliciesDisableTest.java | 1 +
.../pulsar/broker/admin/TopicPoliciesTest.java | 40 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 46 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 2 +-
.../pulsar/broker/admin/v3/PackagesApiTest.java | 1 +
.../apache/pulsar/broker/auth/AuthLogsTest.java | 1 +
.../pulsar/broker/auth/AuthorizationTest.java | 1 +
.../broker/auth/MockedPulsarServiceBaseTest.java | 8 +-
.../broker/cache/ResourceQuotaCacheTest.java | 1 +
.../delayed/InMemoryDeliveryTrackerTest.java | 3 +-
.../broker/intercept/BrokerInterceptorTest.java | 3 +-
.../intercept/BrokerInterceptorUtilsTest.java | 1 +
.../BrokerInterceptorWithClassLoaderTest.java | 2 +-
.../broker/intercept/CounterBrokerInterceptor.java | 9 +-
.../broker/intercept/InterceptFilterOutTest.java | 5 +-
.../intercept/MangedLedgerInterceptorImplTest.java | 14 +-
.../AntiAffinityNamespaceGroupTest.java | 1 +
.../loadbalance/BrokerVersionFilterTest.java | 4 +-
.../loadbalance/LeaderElectionServiceTest.java | 6 +-
.../broker/loadbalance/LoadBalancerTest.java | 19 +-
...kLimit.java => LoadReportNetworkLimitTest.java} | 3 +-
.../loadbalance/ModularLoadManagerImplTest.java | 1 +
.../ModularLoadManagerStrategyTest.java | 3 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 5 +-
.../loadbalance/impl/LoadManagerSharedTest.java | 3 +-
.../loadbalance/impl/OverloadShedderTest.java | 1 +
.../broker/lookup/http/HttpTopicLookupv2Test.java | 5 +-
.../namespace/NamespaceCreateBundlesTest.java | 1 +
.../namespace/NamespaceOwnershipListenerTests.java | 1 +
.../broker/namespace/NamespaceServiceTest.java | 13 +-
.../broker/namespace/NamespaceUnloadingTest.java | 1 +
.../OwnerShipCacheForCurrentServerTest.java | 1 +
.../broker/namespace/OwnershipCacheTest.java | 5 +-
.../broker/protocol/ProtocolHandlerUtilsTest.java | 1 +
.../ProtocolHandlerWithClassLoaderTest.java | 1 +
.../broker/protocol/ProtocolHandlersTest.java | 1 +
.../broker/service/AdvertisedAddressTest.java | 1 +
.../broker/service/BacklogQuotaManagerTest.java | 7 +-
.../pulsar/broker/service/BatchMessageTest.java | 25 +-
.../pulsar/broker/service/BkEnsemblesTestBase.java | 6 +-
.../broker/service/BrokerBkEnsemblesTests.java | 5 +-
.../broker/service/BrokerBookieIsolationTest.java | 5 +-
.../broker/service/BrokerEntryMetadataE2ETest.java | 1 +
.../BrokerServiceAutoSubscriptionCreationTest.java | 3 +-
.../BrokerServiceAutoTopicCreationTest.java | 4 +-
.../pulsar/broker/service/BrokerServiceTest.java | 3 +-
.../service/BrokerServiceThrottlingTest.java | 14 +-
.../pulsar/broker/service/BrokerTestBase.java | 2 -
...istentHashingStickyKeyConsumerSelectorTest.java | 21 +-
.../broker/service/ConsumedLedgersTrimTest.java | 4 +-
.../service/CurrentLedgerRolloverIfFullTest.java | 36 +-
.../broker/service/DistributedIdGeneratorTest.java | 3 +-
.../broker/service/EnableProxyProtocolTest.java | 1 +
.../broker/service/ExclusiveProducerTest.java | 3 +-
...angeAutoSplitStickyKeyConsumerSelectorTest.java | 5 +-
...angeExclusiveStickyKeyConsumerSelectorTest.java | 1 +
.../broker/service/InactiveTopicDeleteTest.java | 2 +-
.../apache/pulsar/broker/service/KeyValueTest.java | 107 +
.../pulsar/broker/service/MaxMessageSizeTest.java | 1 +
...zation.java => MessageIdSerializationTest.java} | 3 +-
.../service/MessagePublishBufferThrottleTest.java | 3 +-
.../pulsar/broker/service/MessageTTLTest.java | 8 +-
.../broker/service/NonPersistentTopicE2ETest.java | 11 +-
.../pulsar/broker/service/NullValueTest.java | 1 +
.../broker/service/OpportunisticStripingTest.java | 3 +-
.../pulsar/broker/service/PartitionKeyTest.java | 4 +-
.../pulsar/broker/service/PeerReplicatorTest.java | 3 +-
.../PersistentDispatcherFailoverConsumerTest.java | 1 +
.../broker/service/PersistentFailoverE2ETest.java | 16 +-
.../service/PersistentMessageFinderTest.java | 23 +-
.../broker/service/PersistentQueueE2ETest.java | 5 +-
.../service/PersistentTopicConcurrentTest.java | 17 +-
.../broker/service/PersistentTopicE2ETest.java | 94 +-
.../pulsar/broker/service/PersistentTopicTest.java | 50 +-
.../PrecisTopicPublishRateThrottleTest.java | 1 +
.../broker/service/PublishRateLimiterTest.java | 6 +-
.../pulsar/broker/service/RackAwareTest.java | 1 +
.../broker/service/ReplicatorGlobalNSTest.java | 1 +
.../broker/service/ReplicatorRateLimiterTest.java | 1 +
.../pulsar/broker/service/ReplicatorTest.java | 14 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 2 +-
.../pulsar/broker/service/ReplicatorTlsTest.java | 2 +-
.../pulsar/broker/service/ResendRequestTest.java | 7 +-
.../pulsar/broker/service/ServerCnxTest.java | 20 +-
.../broker/service/SubscriptionSeekTest.java | 10 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 1 +
.../pulsar/broker/service/TopicOwnerTest.java | 1 +
.../service/TopicPoliciesServiceDisableTest.java | 1 +
.../broker/service/TopicTerminationTest.java | 8 +-
.../service/TransactionMarkerDeleteTest.java | 1 +
.../TransactionMetadataStoreServiceTest.java | 1 +
...ntStickyKeyDispatcherMultipleConsumersTest.java | 163 +
.../broker/service/persistent/ChecksumTest.java | 4 +-
.../service/persistent/DelayedDeliveryTest.java | 4 +-
.../service/persistent/MessageDuplicationTest.java | 47 +-
...herFailoverConsumerStreamingDispatcherTest.java | 6 +-
...rsistentFailoverStreamingDispatcherE2ETest.java | 2 +
...ntStickyKeyDispatcherMultipleConsumersTest.java | 2 +-
...istentStreamingDispatcherBlockConsumerTest.java | 3 +
...eDispatchStreamingDispatcherThrottlingTest.java | 3 +
.../persistent/PersistentSubscriptionTest.java | 1 +
.../PersistentTopicStreamingDispatcherE2ETest.java | 3 +
.../PersistentTopicStreamingDispatcherTest.java | 2 +
.../service/persistent/PersistentTopicTest.java | 4 +-
.../ReplicatedSubscriptionConfigTest.java | 3 +-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 6 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 11 +-
...roducerConsumerTestStreamingDispatcherTest.java | 3 +
.../service/persistent/TopicDuplicationTest.java | 1 +
.../schema/AvroSchemaCompatibilityCheckTest.java | 3 +
.../schema/BookkeeperSchemaStorageTest.java | 1 +
.../broker/service/schema/ClientGetSchemaTest.java | 5 +-
.../schema/JsonSchemaCompatibilityCheckTest.java | 1 +
.../KeyValueSchemaCompatibilityCheckTest.java | 1 +
.../schema/PartitionedTopicsSchemaTest.java | 1 +
...ProtobufNativeSchemaCompatibilityCheckTest.java | 1 +
.../ProtobufSchemaCompatibilityCheckTest.java | 3 +
.../broker/service/schema/SchemaServiceTest.java | 1 +
.../schema/validator/SchemaDataValidatorTest.java | 1 +
...RegistryServiceWithSchemaDataValidatorTest.java | 1 +
.../StreamingEntryReaderTests.java | 48 +-
.../broker/service/utils/ClientChannelHelper.java | 8 +-
.../stats/BookieClientsStatsGeneratorTest.java | 3 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 1 +
.../broker/stats/ManagedCursorMetricsTest.java | 14 +-
.../broker/stats/ManagedLedgerMetricsTest.java | 3 +-
.../pulsar/broker/stats/PrometheusMetricsTest.java | 104 +-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 1 +
.../prometheus/AggregatedNamespaceStatsTest.java | 3 +-
.../NamespaceEventsSystemTopicServiceTest.java | 1 +
.../TopicTransactionBufferRecoverTest.java | 98 +
.../broker/transaction/TransactionConsumeTest.java | 3 +-
.../broker/transaction/TransactionProduceTest.java | 1 +
.../buffer/InMemTransactionBufferReaderTest.java | 5 +-
.../buffer/TransactionBufferClientTest.java | 1 +
.../transaction/buffer/TransactionBufferTest.java | 9 +-
.../buffer/TransactionEntryImplTest.java | 1 +
.../buffer/TransactionLowWaterMarkTest.java | 32 +-
.../buffer/TransactionStablePositionTest.java | 5 +-
.../TransactionCoordinatorClientTest.java | 2 +-
.../TransactionMetaStoreAssignmentTest.java | 7 +-
.../pendingack/PendingAckInMemoryDeleteTest.java | 39 +-
.../pulsar/broker/web/RestExceptionTest.java | 1 +
.../apache/pulsar/broker/web/WebServiceTest.java | 7 +-
.../broker/zookeeper/ClusterMetadataSetupTest.java | 1 +
.../zookeeper/ZooKeeperClientAspectJTest.java | 5 +-
.../ZooKeeperSessionExpireRecoveryTest.java | 3 +-
.../api/AuthenticatedProducerConsumerTest.java | 4 +-
.../AuthenticationTlsHostnameVerificationTest.java | 1 +
.../api/AuthorizationProducerConsumerTest.java | 1 +
.../pulsar/client/api/BrokerServiceLookupTest.java | 47 +-
.../org/apache/pulsar/client/api/BytesKeyTest.java | 1 +
.../client/api/ClientDeduplicationFailureTest.java | 22 +-
.../pulsar/client/api/ClientDeduplicationTest.java | 14 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 11 +-
.../pulsar/client/api/ConsumerAckListTest.java | 6 +-
.../client/api/ConsumerBatchReceiveTest.java | 47 +-
.../pulsar/client/api/ConsumerCleanupTest.java | 1 +
.../pulsar/client/api/ConsumerRedeliveryTest.java | 3 +-
.../pulsar/client/api/DeadLetterTopicTest.java | 1 +
.../client/api/DispatcherBlockConsumerTest.java | 21 +-
.../api/ExposeMessageRedeliveryCountTest.java | 3 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 1 +
.../client/api/KeySharedSubscriptionTest.java | 62 +-
.../apache/pulsar/client/api/MemoryLimitTest.java | 9 +-
.../client/api/MessageDispatchThrottlingTest.java | 5 +-
.../pulsar/client/api/MockBrokerServiceHooks.java | 46 +-
.../client/api/MutualAuthenticationTest.java | 9 +-
.../client/api/NonDurableSubscriptionTest.java | 1 +
.../pulsar/client/api/NonPersistentTopicTest.java | 3 +-
.../pulsar/client/api/PartitionCreationTest.java | 10 +-
.../api/PartitionedProducerConsumerTest.java | 3 +-
.../pulsar/client/api/ProducerCleanupTest.java | 1 +
.../pulsar/client/api/ProducerConsumerBase.java | 4 +-
.../pulsar/client/api/ProducerCreationTest.java | 1 +
.../pulsar/client/api/ProxyProtocolTest.java | 1 +
...MultiListenersWithInternalListenerNameTest.java | 1 +
...tiListenersWithoutInternalListenerNameTest.java | 1 +
.../apache/pulsar/client/api/RetryTopicTest.java | 1 +
.../pulsar/client/api/ServiceUrlProviderTest.java | 7 +-
.../client/api/SimpleProducerConsumerStatTest.java | 5 +-
.../client/api/SimpleProducerConsumerTest.java | 164 +-
.../apache/pulsar/client/api/SimpleSchemaTest.java | 3 +-
.../api/SimpleTypedProducerConsumerTest.java | 3 +-
.../SubscriptionMessageDispatchThrottlingTest.java | 33 +-
.../org/apache/pulsar/client/api/TenantTest.java | 1 +
.../pulsar/client/api/TlsHostVerification.java | 2 +
.../pulsar/client/api/TlsProducerConsumerBase.java | 6 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 9 +-
.../org/apache/pulsar/client/api/TlsSniTest.java | 1 +
.../TokenAuthenticatedProducerConsumerTest.java | 3 +-
...kenOauth2AuthenticatedProducerConsumerTest.java | 6 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 11 +-
.../client/api/v1/V1_ProducerConsumerBase.java | 2 +-
.../client/api/v1/V1_ProducerConsumerTest.java | 13 +-
.../client/impl/AdminApiKeyStoreTlsAuthTest.java | 6 +-
.../impl/BatchMessageIdImplSerializationTest.java | 6 +-
.../impl/BatchMessageIndexAckDisableTest.java | 7 +-
.../client/impl/BatchMessageIndexAckTest.java | 4 +-
.../client/impl/BrokerClientIntegrationTest.java | 31 +-
.../client/impl/CompactedOutBatchMessageTest.java | 2 +
.../pulsar/client/impl/ConnectionPoolTest.java | 1 +
.../client/impl/ConsumeBaseExceptionTest.java | 1 +
.../client/impl/ConsumerAckResponseTest.java | 4 +-
.../client/impl/ConsumerConfigurationTest.java | 1 +
...te.java => ConsumerDedupPermitsUpdateTest.java} | 4 +-
.../client/impl/ConsumerUnsubscribeTest.java | 5 +-
...yStoreTlsProducerConsumerTestWithAuthTest.java} | 4 +-
...oreTlsProducerConsumerTestWithoutAuthTest.java} | 11 +-
.../apache/pulsar/client/impl/KeyStoreTlsTest.java | 1 +
.../pulsar/client/impl/MessageChecksumTest.java | 1 +
.../pulsar/client/impl/MessageChunkingTest.java | 3 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 1 +
.../pulsar/client/impl/MessageParserTest.java | 1 +
.../client/impl/MessagePublishThrottlingTest.java | 1 +
.../pulsar/client/impl/MessageRedeliveryTest.java | 1 +
.../pulsar/client/impl/MultiTopicsReaderTest.java | 51 +-
.../pulsar/client/impl/NegativeAcksTest.java | 1 +
.../client/impl/PatternTopicsConsumerImplTest.java | 10 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 1 +
.../pulsar/client/impl/ProducerSemaphoreTest.java | 2 +-
.../client/impl/PulsarMultiHostClientTest.java | 5 +-
.../pulsar/client/impl/RawMessageSerDeserTest.java | 4 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 23 +-
.../org/apache/pulsar/client/impl/ReaderTest.java | 7 +-
.../pulsar/client/impl/SchemaDeleteTest.java | 3 +-
.../client/impl/SequenceIdWithErrorTest.java | 5 +-
.../pulsar/client/impl/TopicDoesNotExistsTest.java | 2 +-
.../pulsar/client/impl/TopicFromMessageTest.java | 1 +
.../impl/TopicPublishThrottlingInitTest.java | 1 +
.../pulsar/client/impl/TopicsConsumerImplTest.java | 6 +-
.../client/impl/TransactionEndToEndTest.java | 6 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 3 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 15 +-
.../pulsar/common/naming/NamespaceBundleTest.java | 9 +-
.../pulsar/common/naming/NamespaceBundlesTest.java | 68 +-
.../common/naming/ServiceConfigurationTest.java | 7 +-
.../pulsar/compaction/CompactedTopicTest.java | 8 +-
.../apache/pulsar/compaction/CompactionTest.java | 1 +
.../apache/pulsar/compaction/CompactorTest.java | 2 +-
.../service/web/DiscoveryServiceWebTest.java | 59 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 8 +-
.../worker/PulsarFunctionLocalRunTest.java | 27 +-
.../worker/PulsarFunctionPublishTest.java | 2 +-
.../functions/worker/PulsarFunctionTlsTest.java | 4 +-
.../worker/PulsarWorkerAssignmentTest.java | 13 +-
.../apache/pulsar/io/PulsarFunctionAdminTest.java | 5 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 22 +-
.../apache/pulsar/io/PulsarFunctionTlsTest.java | 19 +-
.../pulsar/schema/PartitionedTopicSchemaTest.java | 1 +
.../java/org/apache/pulsar/schema/SchemaTest.java | 35 +
.../SchemaCompatibilityCheckTest.java | 2 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 3 +-
.../pulsar/utils/SimpleTextOutputStreamTest.java | 1 +
.../apache/pulsar/utils/StatsOutputStreamTest.java | 1 +
.../websocket/proxy/ProxyAuthenticationTest.java | 18 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 1 +
.../websocket/proxy/ProxyConfigurationTest.java | 1 +
.../websocket/proxy/ProxyPublishConsumeTest.java | 11 +-
.../proxy/ProxyPublishConsumeTlsTest.java | 3 +-
.../proxy/ProxyPublishConsumeWithoutZKTest.java | 3 +-
.../websocket/proxy/SimpleConsumerSocket.java | 3 +-
.../websocket/proxy/SimpleProducerSocket.java | 2 +-
.../proxy/v1/V1_ProxyAuthenticationTest.java | 17 +-
.../org/apache/pulsar/client/admin/Brokers.java | 6 +
.../org/apache/pulsar/client/admin/Namespaces.java | 16 +-
pulsar-client-admin-shaded/pom.xml | 48 +
.../pulsar/client/admin/internal/BrokersImpl.java | 27 +
.../client/admin/internal/NamespacesImpl.java | 24 +-
.../asynchttpclient/config/ahc-default.properties | 77 -
.../org/asynchttpclient/config/ahc.properties | 1 -
pulsar-client-all/pom.xml | 30 +
.../apache/pulsar/client/api/ReaderBuilder.java | 8 +
pulsar-client-cpp/docker/build-wheels.sh | 3 +-
pulsar-client-cpp/lib/ConsumerImpl.cc | 1 +
pulsar-client-cpp/tests/ConsumerTest.cc | 53 +
pulsar-client-shaded/pom.xml | 31 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 9 +-
.../org/apache/pulsar/admin/cli/CmdBrokers.java | 10 +
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 14 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 10 +-
.../apache/pulsar/client/cli/PulsarClientTool.java | 9 +
.../apache/pulsar/admin/cli/TestCmdPackages.java | 1 +
.../apache/pulsar/client/impl/ConsumerBase.java | 15 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 4 +-
.../pulsar/client/impl/HttpLookupService.java | 21 +-
.../client/impl/MultiTopicsConsumerImpl.java | 6 +-
.../pulsar/client/impl/MultiTopicsReaderImpl.java | 3 +-
.../pulsar/client/impl/PulsarClientImpl.java | 48 +-
.../pulsar/client/impl/ReaderBuilderImpl.java | 15 +-
.../pulsar/client/impl/TopicMessageImpl.java | 6 +-
.../client/impl/conf/ReaderConfigurationData.java | 23 +-
.../pulsar/client/impl/schema/AvroSchema.java | 35 +-
.../pulsar/client/impl/schema/KeyValueSchema.java | 5 +
.../pulsar/client/impl/schema/SchemaUtils.java | 2 +-
.../impl/schema/generic/GenericAvroReader.java | 4 +-
pulsar-client/src/main/resources/ahc.properties | 76 -
.../pulsar/client/api/AuthenticationTest.java | 23 +-
.../apache/pulsar/client/api/ConsumerIdTest.java | 26 +-
.../impl/AcknowledgementsGroupingTrackerTest.java | 2 +-
.../apache/pulsar/client/impl/BuildersTest.java | 3 +-
.../impl/ClientCnxRequestTimeoutQueueTest.java | 4 +-
.../org/apache/pulsar/client/impl/MessageTest.java | 4 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 3 +-
.../pulsar/client/impl/PulsarClientImplTest.java | 6 +-
.../client/impl/PulsarServiceNameResolverTest.java | 2 +-
.../client/impl/UnAckedMessageTrackerTest.java | 2 +-
.../impl/conf/ConfigurationDataUtilsTest.java | 5 +-
...efaultCryptoKeyReaderConfigurationDataTest.java | 2 +-
.../client/impl/schema/DoubleSchemaTest.java | 4 +-
.../pulsar/client/impl/schema/FloatSchemaTest.java | 4 +-
.../impl/schema/ProtobufNativeSchemaUtilsTest.java | 4 +-
.../client/impl/schema/ProtobufSchemaTest.java | 27 +-
.../client/impl/schema/SchemaBuilderTest.java | 90 +-
.../pulsar/client/impl/schema/SchemaInfoTest.java | 66 +-
.../client/tutorial/ContinuousAsyncProducer.java | 2 +-
.../pulsar/client/tutorial/ContinuousProducer.java | 2 +-
.../client/tutorial/SampleAsyncProducer.java | 2 +-
.../client/tutorial/SampleConsumerListener.java | 2 +-
.../client/tutorial/SampleCryptoProducer.java | 2 +-
.../pulsar/client/tutorial/SampleProducer.java | 2 +-
.../pulsar/common/policies/data/ClusterData.java | 10 +-
.../pulsar/common/policies/data/Policies.java | 2 +-
.../apache/pulsar/common/protocol/Commands.java | 8 +-
.../java/org/apache/pulsar/common/stats/Rate.java | 8 +
.../pulsar/common/api/raw/RawMessageImplTest.java | 8 +-
.../common/policies/data/BacklogQuotaTest.java | 1 -
.../common/policies/data/OffloadPoliciesTest.java | 2 +-
.../common/policies/data/PoliciesDataTest.java | 3 +-
.../common/policies/data/ReplicatorStatsTest.java | 1 -
.../common/policies/data/ResourceQuotaTest.java | 5 +-
.../apache/pulsar/common/util/RateLimiterTest.java | 2 +-
.../collections/ConcurrentOpenHashMapTest.java | 4 +-
.../common/util/collections/FieldParserTest.java | 5 +-
.../GrowableArrayBlockingQueueTest.java | 2 +-
.../collections/TripleLongPriorityQueueTest.java | 2 +-
.../common/util/netty/ChannelFuturesTest.java | 4 +-
.../discovery/service/BrokerDiscoveryProvider.java | 21 +-
.../pulsar/discovery/service/DiscoveryService.java | 17 +-
.../pulsar/discovery/service/ServerConnection.java | 6 +-
.../service/web/DiscoveryServiceServlet.java | 41 +-
.../service/web/ZookeeperCacheLoader.java | 190 -
.../discovery/service/BaseDiscoveryTestSetup.java | 40 +-
.../discovery/service/DiscoveryServiceTest.java | 29 +-
.../discovery/service/web/BaseZKStarterTest.java | 33 +-
.../service/web/DiscoveryServiceWebTest.java | 121 +-
...Test.java => MetadataStoreCacheLoaderTest.java} | 24 +-
.../instance/state/BKStateStoreProviderImpl.java | 1 +
.../apache/pulsar/functions/sink/PulsarSink.java | 46 +-
.../pulsar/functions/sink/PulsarSinkTest.java | 166 +
pulsar-functions/localrun-shaded/pom.xml | 48 +
.../pulsar/functions/utils/FunctionInstanceId.java | 12 +-
.../pulsar/functions/utils/SourceConfigUtils.java | 2 +
.../functions/utils/FunctionInstanceIdTest.java | 62 +
.../pulsar/functions/worker/WorkerUtilsTest.java | 24 +-
.../TestPollingZooKeeperConfigurationProvider.java | 2 +-
.../TestPropertiesFileConfigurationProvider.java | 6 +-
.../pulsar/io/flume/sink/StringSinkTests.java | 10 +-
.../pulsar/io/flume/source/StringSourceTests.java | 2 +-
.../resources/flume-conf-with-envvars.properties | 1 -
pulsar-io/kafka/pom.xml | 18 +
.../apache/pulsar/io/kafka/AvroSchemaCache.java | 81 +
.../pulsar/io/kafka/ByteBufferSchemaWrapper.java | 85 +
.../pulsar/io/kafka/BytesWithKafkaSchema.java | 16 +-
.../pulsar/io/kafka/KafkaAbstractSource.java | 73 +-
.../apache/pulsar/io/kafka/KafkaBytesSource.java | 212 +-
.../apache/pulsar/io/kafka/KafkaStringSource.java | 12 +-
.../io/kafka/ByteBufferSchemaWrapperTest.java | 105 +
.../pulsar/io/kafka/KafkaBytesSourceTest.java | 164 +
.../io/kafka/source/KafkaAbstractSourceTest.java | 154 +-
.../metadata/cache/impl/MetadataCacheImpl.java | 13 +-
.../apache/pulsar/metadata/MetadataCacheTest.java | 83 +
.../bookkeeper/BookKeeperPackagesStorageTest.java | 2 +-
.../proxy/server/BrokerDiscoveryProvider.java | 16 +-
.../apache/pulsar/proxy/server/ProxyService.java | 14 +-
.../proxy/server/AuthedAdminProxyHandlerTest.java | 2 +-
.../proxy/server/ProxyAdditionalServletTest.java | 1 -
.../ProxyAuthenticatedProducerConsumerTest.java | 1 -
.../proxy/server/ProxyAuthenticationTest.java | 8 +-
.../server/ProxyConnectionThrottlingTest.java | 1 -
.../server/ProxyEnableHAProxyProtocolTest.java | 1 -
.../pulsar/proxy/server/ProxyIsAHttpProxyTest.java | 16 +-
.../proxy/server/ProxyKeyStoreTlsTestWithAuth.java | 1 -
.../server/ProxyKeyStoreTlsTestWithoutAuth.java | 1 -
.../proxy/server/ProxyLookupThrottlingTest.java | 1 -
.../pulsar/proxy/server/ProxyParserTest.java | 1 -
.../proxy/server/ProxyRolesEnforcementTest.java | 8 +-
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 7 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 1 -
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 1 -
.../pulsar/proxy/server/ProxyTlsTestWithAuth.java | 1 -
.../proxy/server/ProxyWithAuthorizationTest.java | 6 +-
.../SuperUserAuthedAdminProxyHandlerTest.java | 2 +-
.../server/UnauthedAdminProxyHandlerTest.java | 2 +-
pulsar-sql/presto-distribution/LICENSE | 8 +-
pulsar-sql/presto-pulsar/pom.xml | 29 +
.../pulsar/sql/presto/PulsarConnectorCache.java | 2 +-
.../pulsar/sql/presto/PulsarConnectorConfig.java | 12 +
.../apache/pulsar/sql/presto/PulsarMetadata.java | 111 +-
.../pulsar/sql/presto/PulsarRecordCursor.java | 64 +-
.../pulsar/sql/presto/PulsarSplitManager.java | 11 +-
.../pulsar/sql/presto/util/CacheSizeAllocator.java | 36 +-
.../presto/util/NoStrictCacheSizeAllocator.java | 84 +
.../sql/presto/util/NullCacheSizeAllocator.java | 20 +-
.../pulsar/sql/presto/util/package-info.java | 11 +-
.../pulsar/sql/presto/TestCacheSizeAllocator.java | 175 +
.../sql/presto/TestNoStrictCacheSizeAllocator.java | 48 +
.../pulsar/sql/presto/TestPulsarConnector.java | 7 +-
.../sql/presto/TestPulsarConnectorConfig.java | 1 +
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 7 +-
.../sql/presto/decoder/avro/TestAvroDecoder.java | 12 +-
.../sql/presto/decoder/json/TestJsonDecoder.java | 12 +-
.../proxy/socket/client/PerformanceClient.java | 14 +-
.../apache/pulsar/testclient/BrokerMonitor.java | 2 +-
.../pulsar/testclient/LoadSimulationClient.java | 2 +-
.../testclient/LoadSimulationController.java | 4 +-
.../pulsar/testclient/ManagedLedgerWriter.java | 10 +-
.../apache/pulsar/testclient/PerfClientUtils.java | 15 +
.../pulsar/testclient/PerformanceConsumer.java | 12 +-
.../pulsar/testclient/PerformanceProducer.java | 63 +-
.../pulsar/testclient/PerformanceReader.java | 8 +-
.../pulsar/testclient/PerformanceProducerTest.java | 33 +
.../pulsar/websocket/AbstractWebSocketHandler.java | 2 +-
.../WebSocketHttpServletRequestWrapper.java | 48 +
.../websocket/AbstractWebSocketHandlerTest.java | 7 +-
.../pulsar/zookeeper/LocalBookkeeperEnsemble.java | 12 +-
.../zookeeper/ZkBookieRackAffinityMapping.java | 7 +-
site2/docs/admin-api-packages.md | 12 +-
site2/docs/administration-geo.md | 38 +
site2/docs/client-libraries-dotnet.md | 87 +-
site2/docs/client-libraries-websocket.md | 13 +
site2/docs/concepts-clients.md | 2 +-
site2/docs/concepts-messaging.md | 21 +-
site2/docs/concepts-proxy-sni-routing.md | 44 +-
site2/docs/developing-binary-protocol.md | 2 +-
site2/docs/functions-runtime.md | 9 +-
site2/docs/reference-configuration.md | 50 +-
site2/docs/reference-metrics.md | 58 +-
site2/docs/reference-terminology.md | 4 +-
site2/tools/build-site.sh | 3 +-
.../website/blog/2020-06-18-Apache-Pulsar-2-6-0.md | 4 +-
site2/website/data/users.js | 5 +
site2/website/release-notes.md | 175 +
site2/website/releases.json | 1 +
site2/website/static/swagger/2.7.1/swagger.json | 17929 +++++++++++++++++++
.../static/swagger/2.7.1/swaggerfunctions.json | 1651 ++
.../website/static/swagger/2.7.1/swaggersink.json | 1104 ++
.../static/swagger/2.7.1/swaggersource.json | 1064 ++
.../version-2.4.0/developing-binary-protocol.md | 2 +-
.../version-2.5.0/functions-runtime.md | 9 +-
.../version-2.5.1/developing-binary-protocol.md | 2 +-
.../version-2.5.1/functions-runtime.md | 9 +-
.../version-2.5.2/developing-binary-protocol.md | 2 +-
.../version-2.5.2/functions-runtime.md | 9 +-
.../version-2.6.0/client-libraries-dotnet.md | 87 +-
.../version-2.6.0/concepts-clients.md | 2 +-
.../version-2.6.0/developing-binary-protocol.md | 2 +-
.../version-2.6.0/functions-runtime.md | 9 +-
.../version-2.6.0/reference-configuration.md | 14 +-
.../version-2.6.0/reference-terminology.md | 4 +-
.../version-2.6.1/client-libraries-dotnet.md | 87 +-
.../version-2.6.1/concepts-clients.md | 2 +-
.../version-2.6.1/developing-binary-protocol.md | 2 +-
.../version-2.6.1/functions-runtime.md | 9 +-
.../version-2.6.1/reference-configuration.md | 12 +-
.../version-2.6.1/reference-terminology.md | 4 +-
.../version-2.6.2/client-libraries-dotnet.md | 87 +-
.../version-2.6.2/concepts-clients.md | 2 +-
.../version-2.6.2/developing-binary-protocol.md | 2 +-
.../version-2.6.2/functions-runtime.md | 9 +-
.../version-2.6.2/reference-configuration.md | 12 +-
.../version-2.6.2/reference-terminology.md | 4 +-
.../version-2.6.3/client-libraries-dotnet.md | 87 +-
.../version-2.6.3/concepts-clients.md | 2 +-
.../version-2.6.3/developing-binary-protocol.md | 2 +-
.../version-2.6.3/functions-runtime.md | 9 +-
.../version-2.6.3/reference-configuration.md | 18 +-
.../version-2.6.3/reference-terminology.md | 4 +-
.../version-2.7.0/client-libraries-dotnet.md | 87 +-
.../version-2.7.0/concepts-clients.md | 2 +-
.../version-2.7.0/developing-binary-protocol.md | 2 +-
.../version-2.7.0/functions-runtime.md | 9 +-
.../version-2.7.0/reference-configuration.md | 48 +-
.../version-2.7.0/reference-terminology.md | 4 +-
.../version-2.7.1/client-libraries-dotnet.md | 87 +-
.../version-2.7.1/concepts-clients.md | 2 +-
.../version-2.7.1/developing-binary-protocol.md | 2 +-
.../version-2.7.1/functions-runtime.md | 9 +-
.../version-2.7.1/reference-configuration.md | 48 +-
.../version-2.7.1/reference-terminology.md | 4 +-
site2/website/versions.json | 1 +
.../tests/integration/io/GenericRecordSource.java | 88 +
.../tests/integration/io/TestPropertySource.java | 63 +
.../tests/integration/cli/PulsarVersionTest.java | 73 +
.../tests/integration/io/AvroKafkaSourceTest.java | 496 +
.../integration/io/GenericRecordSourceTest.java | 234 +
.../integration/io/PulsarSourcePropertyTest.java | 170 +
.../tests/integration/presto/TestBasicPresto.java | 34 +
.../integration/presto/TestPulsarSQLBase.java | 3 +-
.../integration/src/test/resources/pulsar-cli.xml | 1 +
...lsar-function-state.xml => pulsar-function.xml} | 6 +-
.../src/test/resources/pulsar-messaging.xml | 1 +
tests/integration/src/test/resources/pulsar.xml | 2 +-
tiered-storage/file-system/pom.xml | 12 +-
tiered-storage/jcloud/pom.xml | 19 +
.../jcloud/impl/BufferedOffloadStreamTest.java | 38 +-
.../offload/jcloud/impl/DataBlockHeaderTest.java | 2 +-
.../offload/jcloud/impl/DataBlockHeaderV2Test.java | 2 +-
.../offload/jcloud/impl/MockManagedLedger.java | 6 +-
.../provider/TieredStorageConfigurationTests.java | 10 +-
606 files changed, 29716 insertions(+), 3415 deletions(-)
