This is an automated email from the ASF dual-hosted git repository.
mattisonchao pushed a change to branch offload-web-response-from-metadata-thread
in repository https://gitbox.apache.org/repos/asf/pulsar.git
omit f52e5647724 [improve][broker] Offload web response from metadata
thread for list tenants/namespaces/clusters
add e1afa05bc2a [feat] PIP-454: Metadata Store Migration Framework
(implementation) (#25219)
add e44f36a1b2a [fix][ws] Fix issue where
metadataStoreAllowReadOnlyOperations setting is ignored by WebSocket server
(#25281)
add 629ddebeec0 [fix] Fix typos in class Message and Producer (#25265)
add f83251a57fd [fix][broker] Support namespace unsubscribe when bundles
are unloaded (#25276)
add e902c689cb3 [feat][monitor] PIP-447 for Customizable Prometheus
Labels for Topic Metrics (#24991)
add e0fb3015da0 [cleanup] Refactored Backoff to be more consistent and
intuitive to use (#25278)
add 0bc9dcbca3f [improve][broker] Update netty allocator default chunk
size from 4MB to 8MB, and move internal JVM opts from PULSAR_EXTRA_OPTS to OPTS
(#25274)
add de5221b2a45 [fix][client] Fix async APIs to return failed futures on
validation errors (#25287)
add 8332499ab2d [improve][ml] Clean up managed-ledger code: deduplicate
logic and use shared utilities (#25298)
add c70f2637611 [fix][build] Fix compilation issues for PR #25219 changes
after merging conflicting PR #25278 (#25300)
add 35dae97c0bf [fix][broker] Return failed future instead of throwing
exception in async methods (#25289)
add ec4bb77e621 [cleanup] PIP-457: Remove support for V1 topic names and
V1 Admin API (#25275)
add 5081c02e7f5 [fix][sec] Bump org.apache.zookeeper:zookeeper from 3.9.4
to 3.9.5 (#25303)
add c83cafc12eb [fix][offload] Close all resources in
BlobStoreBackedReadHandleImplV2.closeAsync (#25296)
add 8798a466230 [improve][CI] Add Copilot instructions based on Pulsar
Java coding conventions (#25305)
add f1aac3d57fb [improve][broker]Part-2 of PIP-433 add validation when
enabling namespace-level Geo-Replication (#25170)
add 6c357f6c909 [fix] Fix flaky
testEstimatedTimeBasedBacklogQuotaCheckWhenNoBacklog (#25307)
add b171b057b71 [fix][test] Fix flaky PulsarDebeziumOracleSourceTest
(#25314)
add d0fa3637e4c [fix][test] Fix flaky OneWayReplicatorUsingGlobalZKTest
cleanup (#25313)
add 0495c8a16e4 [fix] Fix flaky
OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316)
add ce5bc1364b1 [improve][test] Introduce shared Pulsar cluster for faster
integration tests (#25311)
add 735b429ca33 [fix] PIP-457: Remove support for V1 topic names and V1
Admin API (implementation) (#25304)
add 5067d0d4a58 [fix][test] Fix flaky ConnectionTimeoutTest by correcting
latch count (#25320)
add 2e3e78d992e [cleanup] PIP-457: Remove NamespaceName.isGlobal() and
TopicName.isGlobal() (#25319)
add 1b5c818a538 [fix][client] Fail messages immediately in ProducerImpl
when in terminal state (#25317)
add a30deb4f6d2 [fix][io][kca] kafka headers silently dropped (#25325)
add 3936ce49e78 [fix][broker] Handle missing replicator during snapshot
request processing (#25266)
add 5ddc94993fd [cleanup] Convert 15 test classes to SharedPulsarBaseTest
(#25318)
add 3222c561a77 [cleanup] Convert 10 test classes to SharedPulsarBaseTest
(#25327)
add ae5c70c2789 [improve] Add secondary index support to MetadataStore
(#25328)
add be87cd9bfe3 [fix][broker]system topic was created with different
partitions acrossing clusters after enabled namespace-level replication (#25312)
add 2bd9dd031dd [improve][build] Upgrade LightProto to 0.6.1 (#25332)
add 7f6bc233dc3 [cleanup] Convert 13 test classes to SharedPulsarBaseTest
(#25331)
add ff9f1b90d25 [fix][test] Fix flaky
PersistentTopicTerminateTest.testRecoverAfterTerminate (#25345)
add af92a5f914d [fix][broker] Fix concurrency bug in
BucketDelayedDeliveryTracker (#25346)
add f9cf14027b6 [improve][ml] Migrate managed-ledger from protobuf to
LightProto (#25336)
add 2aad1ce99ae [fix][test] Fix flaky
ResendRequestTest.testFailoverSingleAckedNormalTopic (#25343)
add 0268ee3e78b [fix][test] Fix flaky
PulsarFunctionTlsTest.testFunctionsCreation (#25341)
add 92b7cdc7f32 [fix][test] Fix flaky
MetadataStoreTest.testThreadSwitchOfZkMetadataStore (#25347)
add c958b937d85 [improve][io] Upgrade Debezium to 3.4.2 and Kafka
Client/Connect to 4.1.1 (#25335)
add bb0e1cb70ed [fix][test] Fix flaky
TopicTerminationTest.testCreatingProducerTasksCleanupWhenOnTerminatedTopic
(#25355)
add 5d03ef31401 [fix][test] Fix flaky TopicListSizeResultCacheTest
concurrent requests test (#25357)
add 39fa6d5abab [fix][broker] Fix race condition in ServerCnx
producer/consumer async callbacks (#25352)
add 1064f5e1929 [fix][test] Make
ClusterMigrationTest.testClusterMigrationWithReplicationBacklog more robust
(#25330)
add 9f4bad3f5c3 [improve][broker] Migrate remaining broker proto files
from protobuf to LightProto (#25337)
add 8114d5df0ad [fix][test] Fix flaky ManagedCursorTest.testSkipEntries
(#25339)
add a1b1a9efecb [fix][test] Fix flaky
ReplicatorRateLimiterTest.testReplicatorRateLimiterMessageReceivedAllMessages
(#25340)
add b747b33b04d [fix][test] Fix flaky
ConsumedLedgersTrimTest.testAdminTrimLedgers (#25342)
add db221ad7642 [fix][test] Fix flaky
PersistentTopicTest.testBacklogCursor (#25348)
add d8c761fe214 [fix][test] Fix flaky
ShadowTopicTest.testConsumeShadowMessageWithoutCache (#25354)
add 74f4e5a123b [fix][test] Fix flaky
ReplicatorTest.testResumptionAfterBacklogRelaxed (#25358)
add 041510b9a0c [fix][sec] Bump google.golang.org/grpc from 1.60.0 to
1.79.3 in /pulsar-function-go (#25353)
add 2144968bd0a [fix][test] Fix flaky
ConsumedLedgersTrimTest.testAdminTrimLedgers (#25360)
add 543a75d902e [fix][test] Fix flaky
ResendRequestTest.testFailoverSingleAckedNormalTopic (#25364)
add a3ae70545f3 [fix][test] Fix flaky
MessagePublishBufferThrottleTest.testBlockByPublishRateLimiting (#25365)
add 6e577f0bc5a [fix][ci] Disable trivy-action (#25373)
add 29b65a4bd2f [fix][broker] Fix IllegalArgumentException in
BucketDelayedDeliveryTracker.addMessage (#25371)
add 4e7ee9448fc [fix][test] Fix flaky
ExtensibleLoadManagerImplTest.testLoadBalancerServiceUnitTableViewSyncer
(#25378)
add 109761ccd4d [fix][test] Fix thread leaks in ManagedLedgerTest and
PulsarMockBookKeeper (#25377)
add d5288178e50 [fix][test] Fix thread leaks in multiple tests and
KinesisSink (#25376)
add 7a919db3935 [fix][test] Whitelist SharedPulsarCluster threads in
thread leak detector (#25375)
add a27988bc109 [fix][test] Fix thread leaks in
ClientDeduplicationFailureTest and RackAwareTest (#25374)
add 2500c3d1839 [fix][broker] Fix ExtensibleLoadManagerImpl stuck
Assigning bundle state after broker restart (#25379)
add be66ba97fe1 [improve][client] Enable configurable preemptive OAuth2
token refresh (#25363)
add 86e9e64c31c [cleanup] PIP-462: Remove Etcd metadata store backend
(#25329)
add 765c46e2747 [cleanup] Convert 10 test classes to SharedPulsarBaseTest
(#25338)
add 953d092b10a [fix][test] Fix flaky
PersistentStickyKeyDispatcherMultipleConsumersClassicTest.testSkipRedeliverTemporally
(#25385)
add ba851d3784f [feat][bookkeeper] add certs refresh (#25370)
add ce3429ce878 [fix][test] Fix flaky
OneWayReplicatorUsingGlobalZKTest.cleanup (#25389)
add 3bc834f2fa8 [fix][client] Fix stale Healthy state in
SameAuthParamsLookupAutoClusterFailover causing flaky test (#25388)
add 7e5839c1626 [cleanup] Convert 30 test classes to SharedPulsarBaseTest
(#25381)
add 78281fd0450 [improve][pip] PIP-464: Deprecate legacy Jackson
JsonSchema format for SchemaType.JSON (#25361)
add 08d89a2ea1a [improve][broker] PIP-464: Strict Avro schema validation
for SchemaType.JSON (#25362)
add 5fa5f98bbcc [improve][broker] Offload web response from metadata
thread for list tenants/namespaces/clusters
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f52e5647724)
\
N -- N -- N refs/heads/offload-web-response-from-metadata-thread
(5fa5f98bbcc)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/copilot-instructions.md | 282 +++
.github/workflows/ci-go-functions.yaml | 2 +-
.github/workflows/pulsar-ci.yaml | 40 +-
bin/bookkeeper | 20 +
bin/function-localrunner | 29 +-
bin/pulsar | 25 +
bin/pulsar-admin-common.cmd | 24 +
bin/pulsar-admin-common.sh | 24 +
bin/pulsar-perf | 24 +
.../pulsar/client/TlsProducerConsumerTest.java | 12 +-
.../pulsar/tests/ThreadLeakDetectorListener.java | 23 +-
conf/bkenv.sh | 3 +-
conf/bookkeeper.conf | 5 +-
conf/broker.conf | 14 +-
conf/pulsar_env.sh | 3 -
conf/pulsar_tools_env.sh | 3 +-
conf/standalone.conf | 4 -
.../terraform-ansible/templates/pulsar_env.sh | 3 -
distribution/server/src/assemble/LICENSE.bin.txt | 6 +-
.../PrometheusMetricsProviderConfigTest.java | 14 +-
managed-ledger/pom.xml | 17 +-
.../apache/bookkeeper/mledger/LedgerOffloader.java | 4 +-
.../apache/bookkeeper/mledger/ManagedLedger.java | 2 +-
.../mledger/ManagedLedgerFactoryConfig.java | 6 +-
.../mledger/MetadataCompressionConfig.java | 14 +-
.../mledger/impl/EntryCountEstimator.java | 18 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 177 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 135 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 167 +-
.../mledger/impl/ManagedLedgerOfflineBacklog.java | 8 +-
.../apache/bookkeeper/mledger/impl/MetaStore.java | 4 +-
.../bookkeeper/mledger/impl/MetaStoreImpl.java | 125 +-
.../mledger/impl/NullLedgerOffloader.java | 13 +-
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 16 +-
.../mledger/impl/ReadOnlyCursorImpl.java | 4 +-
.../mledger/impl/ReadOnlyManagedLedgerImpl.java | 23 +-
.../mledger/impl/ShadowManagedLedgerImpl.java | 33 +-
.../mledger/impl/cache/RangeEntryCacheImpl.java | 26 +-
.../bookkeeper/mledger/offload/OffloadUtils.java | 35 +-
.../mledger/impl/EntryCacheManagerTest.java | 4 +-
.../bookkeeper/mledger/impl/EntryCacheTest.java | 4 +-
.../mledger/impl/EntryCountEstimatorTest.java | 16 +-
...ManagedCursorIndividualDeletedMessagesTest.java | 57 +-
.../impl/ManagedCursorInfoMetadataTest.java | 44 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 36 +-
.../mledger/impl/ManagedLedgerBkTest.java | 13 +-
.../impl/ManagedLedgerFactoryShutdownTest.java | 25 +-
.../impl/ManagedLedgerInfoMetadataTest.java | 57 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 40 +-
.../bookkeeper/mledger/impl/MetaStoreImplTest.java | 15 +-
.../impl/OffloadEvictUnusedLedgersTest.java | 2 +-
.../mledger/impl/OffloadLedgerDeleteTest.java | 48 +-
.../mledger/impl/OffloadPrefixReadTest.java | 24 +-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 76 +-
.../bookkeeper/mledger/impl/PositionTest.java | 7 +-
.../mledger/offload/OffloadUtilsTest.java | 26 +-
pip/pip-447.md | 55 +-
pip/pip-457.md | 204 ++
pip/pip-462.md | 117 +
pip/pip-464.md | 213 ++
pom.xml | 45 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 30 +-
.../authorization/PulsarAuthorizationProvider.java | 16 +-
.../pulsar/broker/resources/BaseResources.java | 14 +-
.../broker/resources/NamespaceResources.java | 17 +
.../pulsar/broker/resources/TenantResources.java | 152 +-
.../broker/resources/TopicResourcesTest.java | 10 -
.../TopicListSizeResultCacheTest.java | 33 +-
pulsar-broker/pom.xml | 14 +-
.../apache/pulsar/PulsarClusterMetadataSetup.java | 9 +-
.../pulsar/PulsarClusterMetadataTeardown.java | 15 +-
.../org/apache/pulsar/broker/PulsarService.java | 70 +-
.../apache/pulsar/broker/admin/AdminResource.java | 81 +-
.../pulsar/broker/admin/impl/BrokersBase.java | 13 +-
.../pulsar/broker/admin/impl/ClustersBase.java | 17 +-
.../broker/admin/impl/MetadataMigrationBase.java | 116 +
.../pulsar/broker/admin/impl/NamespacesBase.java | 728 ++++--
.../broker/admin/impl/PersistentTopicsBase.java | 392 +---
.../broker/admin/impl/ResourceQuotasBase.java | 5 -
.../pulsar/broker/admin/impl/TenantsBase.java | 23 +-
.../pulsar/broker/admin/impl/TransactionsBase.java | 6 +-
.../apache/pulsar/broker/admin/v1/BrokerStats.java | 54 -
.../org/apache/pulsar/broker/admin/v1/Brokers.java | 31 -
.../apache/pulsar/broker/admin/v1/Clusters.java | 31 -
.../apache/pulsar/broker/admin/v1/Functions.java | 32 -
.../apache/pulsar/broker/admin/v1/Namespaces.java | 1823 ---------------
.../broker/admin/v1/NonPersistentTopics.java | 299 ---
.../pulsar/broker/admin/v1/PersistentTopics.java | 1137 ----------
.../apache/pulsar/broker/admin/v1/Properties.java | 33 -
.../pulsar/broker/admin/v1/ResourceQuotas.java | 126 --
.../pulsar/broker/admin/v1/SchemasResource.java | 389 ----
.../pulsar/broker/admin/v1/package-info.java | 19 -
.../v2/{Brokers.java => MetadataMigration.java} | 11 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 164 +-
.../broker/admin/v2/NonPersistentTopics.java | 14 +-
.../bucket/BookkeeperBucketSnapshotStorage.java | 7 +-
.../pulsar/broker/delayed/bucket/Bucket.java | 5 +-
.../bucket/BucketDelayedDeliveryTracker.java | 51 +-
.../broker/delayed/bucket/ImmutableBucket.java | 33 +-
.../broker/delayed/bucket/MutableBucket.java | 20 +-
.../channel/ServiceUnitStateChannelImpl.java | 10 +-
...ServiceUnitStateMetadataStoreTableViewImpl.java | 4 +-
.../channel/ServiceUnitStateTableViewBase.java | 5 -
.../broker/loadbalance/impl/LoadManagerShared.java | 4 +-
.../pulsar/broker/lookup/TopicLookupBase.java | 145 +-
.../pulsar/broker/lookup/v1/TopicLookup.java | 96 -
.../pulsar/broker/lookup/v1/package-info.java | 19 -
.../pulsar/broker/namespace/NamespaceService.java | 63 +-
.../pulsar/broker/namespace/ServiceUnitUtils.java | 12 +-
.../pulsar/broker/service/AbstractReplicator.java | 13 +-
.../pulsar/broker/service/AbstractTopic.java | 62 +
.../pulsar/broker/service/BacklogQuotaManager.java | 4 +-
.../pulsar/broker/service/BrokerService.java | 168 +-
.../pulsar/broker/service/HealthChecker.java | 26 +-
.../org/apache/pulsar/broker/service/Producer.java | 2 +-
.../service/PulsarMetadataEventSynchronizer.java | 9 +-
.../apache/pulsar/broker/service/ServerCnx.java | 62 +-
.../SystemTopicBasedTopicPoliciesService.java | 4 +-
.../org/apache/pulsar/broker/service/Topic.java | 4 +-
.../pulsar/broker/service/TopicListService.java | 14 +-
.../service/nonpersistent/NonPersistentTopic.java | 61 +-
.../PersistentDispatcherMultipleConsumers.java | 21 +-
...rsistentDispatcherMultipleConsumersClassic.java | 11 +-
.../PersistentDispatcherSingleActiveConsumer.java | 12 +-
.../persistent/PersistentMessageExpiryMonitor.java | 10 +-
.../persistent/PersistentMessageFinder.java | 2 +-
.../service/persistent/PersistentReplicator.java | 9 +-
.../broker/service/persistent/PersistentTopic.java | 89 +-
.../ReplicatedSubscriptionsController.java | 6 +
.../service/schema/BookkeeperSchemaStorage.java | 227 +-
.../schema/JsonSchemaCompatibilityCheck.java | 29 +-
.../service/schema/SchemaRegistryService.java | 13 +-
.../service/schema/SchemaRegistryServiceImpl.java | 75 +-
.../schema/validator/SchemaDataValidator.java | 20 +-
...hemaRegistryServiceWithSchemaDataValidator.java | 18 +-
.../validator/StructSchemaDataValidator.java | 33 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 21 +-
.../prometheus/PrometheusMetricsGenerator.java | 3 +-
.../pulsar/broker/stats/prometheus/TopicStats.java | 461 ++--
.../pulsar/broker/systopic/SystemTopicClient.java | 3 +-
.../pendingack/impl/PendingAckHandleImpl.java | 8 +-
.../pulsar/broker/web/PulsarWebResource.java | 95 +-
.../common/naming/NamespaceBundleFactory.java | 6 +-
.../compaction/PulsarCompactionServiceFactory.java | 10 +-
.../compaction/StrategicTwoPhaseCompactor.java | 2 +-
.../src/main/proto/TransactionPendingAck.proto | 2 +-
.../impl/ConsumerUnsubscribeIntegrationTest.java | 24 +-
.../CustomizedManagedLedgerStorageForTest.java | 8 +-
.../PersistentMessageExpiryMonitorMockTest.java | 11 +-
.../LedgerLostAndSkipNonRecoverableTest.java | 39 +-
.../apache/pulsar/broker/SLAMonitoringTest.java | 10 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 57 +-
.../broker/admin/AdminApiGetLastMessageIdTest.java | 2 +-
.../broker/admin/AdminApiHealthCheckTest.java | 36 +-
.../pulsar/broker/admin/AdminApiOffloadTest.java | 4 +-
.../broker/admin/AdminApiSchemaAutoUpdateTest.java | 18 +-
.../admin/AdminApiSchemaJsonValidationTest.java | 217 ++
.../pulsar/broker/admin/AdminApiSchemaTest.java | 11 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 231 +-
.../org/apache/pulsar/broker/admin/AdminTest.java | 210 +-
.../pulsar/broker/admin/AdminTopicApiTest.java | 45 +-
.../admin/AnalyzeBacklogSubscriptionTest.java | 57 +-
.../admin/BrokerEndpointsAuthorizationTest.java | 9 +-
.../admin/ClusterEndpointsAuthorizationTest.java | 4 +
.../broker/admin/CreateSubscriptionTest.java | 110 +-
.../broker/admin/IncrementPartitionsTest.java | 15 +-
.../pulsar/broker/admin/NamespaceAuthZTest.java | 3 +-
.../apache/pulsar/broker/admin/NamespacesTest.java | 473 ++--
.../pulsar/broker/admin/NamespacesV2Test.java | 6 +-
.../pulsar/broker/admin/PersistentTopicsTest.java | 10 +-
.../admin/TenantEndpointsAuthorizationTest.java | 4 +
.../pulsar/broker/admin/TopicMessageTTLTest.java | 12 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 5 +-
.../pulsar/broker/admin/v1/V1AdminApi2Test.java | 829 -------
.../pulsar/broker/admin/v1/V1AdminApiTest.java | 2140 ------------------
.../apache/pulsar/broker/auth/AuthLogsTest.java | 2 +-
.../pulsar/broker/auth/AuthorizationTest.java | 216 +-
.../pulsar/broker/cache/BundlesQuotasTest.java | 2 +-
.../BookkeeperBucketSnapshotStorageTest.java | 90 +-
.../broker/delayed/MockBucketSnapshotStorage.java | 10 +-
...cketDelayedDeliveryTrackerThreadSafetyTest.java | 21 +
.../AntiAffinityNamespaceGroupTest.java | 20 +-
.../broker/loadbalance/LoadBalancerTest.java | 74 +-
.../loadbalance/LoadBalancerTestingUtils.java | 6 +-
.../loadbalance/SimpleLoadManagerImplTest.java | 28 +-
.../AntiAffinityNamespaceGroupExtensionTest.java | 2 +-
.../ExtensibleLoadManagerImplBaseTest.java | 4 +-
.../extensions/ExtensibleLoadManagerImplTest.java | 66 +-
.../channel/ServiceUnitStateChannelTest.java | 62 +-
.../impl/ModularLoadManagerImplTest.java | 42 +-
.../broker/lookup/http/HttpTopicLookupv2Test.java | 49 +-
.../broker/namespace/NamespaceServiceTest.java | 44 +-
.../broker/namespace/NamespaceUnloadingTest.java | 4 +-
.../broker/namespace/OwnershipCacheTest.java | 16 +-
.../RGUsageMTAggrWaitForAllMsgsTest.java | 4 +-
.../ResourceGroupUsageAggregationTest.java | 4 +-
.../broker/service/BacklogQuotaManagerTest.java | 6 +-
.../service/BatchMessageBrokerRestartTest.java | 120 +
.../pulsar/broker/service/BatchMessageTest.java | 279 +--
.../BatchMessageWithBatchIndexLevelTest.java | 10 +-
.../broker/service/BrokerBkEnsemblesTest.java | 16 +-
.../broker/service/BrokerBookieIsolationTest.java | 32 +-
.../broker/service/BrokerEntryMetadataE2ETest.java | 2 +-
.../BrokerServiceAutoTopicCreationTest.java | 19 -
.../BrokerServiceBundlesCacheInvalidationTest.java | 28 +-
.../broker/service/BrokerServiceChaosTest.java | 5 +-
.../pulsar/broker/service/BrokerServiceTest.java | 13 +-
.../pulsar/broker/service/BrokerTestBase.java | 7 +-
.../CanReconnectZKClientPulsarServiceBaseTest.java | 12 +-
.../broker/service/ClusterMigrationTest.java | 73 +-
.../broker/service/ConsumedLedgersTrimTest.java | 128 +-
.../service/CurrentLedgerRolloverIfFullTest.java | 24 +-
...eateTopicToRemoteClusterForReplicationTest.java | 5 +-
.../broker/service/ExclusiveProducerTest.java | 42 +-
.../broker/service/InactiveTopicDeleteTest.java | 28 +-
.../apache/pulsar/broker/service/KeyValueTest.java | 29 +-
.../service/ManagedLedgerCompressionTest.java | 12 +-
.../broker/service/ManagedLedgerConfigTest.java | 30 +-
.../service/MessagePublishBufferThrottleTest.java | 60 +-
.../pulsar/broker/service/NullValueTest.java | 65 +-
.../broker/service/OneWayReplicatorTest.java | 46 +-
.../broker/service/OneWayReplicatorTestBase.java | 46 +-
...OneWayReplicatorUsingGlobalPartitionedTest.java | 7 +-
.../service/OneWayReplicatorUsingGlobalZKTest.java | 153 +-
.../broker/service/OpportunisticStripingTest.java | 2 +-
.../pulsar/broker/service/PartitionKeyTest.java | 24 +-
.../pulsar/broker/service/PeerReplicatorTest.java | 14 +-
.../PersistentDispatcherFailoverConsumerTest.java | 4 +-
.../broker/service/PersistentFailoverE2ETest.java | 6 +-
.../service/PersistentMessageFinderTest.java | 80 +-
.../broker/service/PersistentQueueE2ETest.java | 12 +-
.../service/PersistentTopicConcurrentTest.java | 2 +-
.../broker/service/PersistentTopicE2ETest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 21 +-
.../pulsar/broker/service/RackAwareTest.java | 4 +-
.../broker/service/ReplicatedSubscriptionTest.java | 24 +-
.../broker/service/ReplicatorGlobalNSTest.java | 10 +-
.../broker/service/ReplicatorRateLimiterTest.java | 23 +-
.../service/ReplicatorRemoveClusterTest.java | 1 -
.../pulsar/broker/service/ReplicatorTest.java | 39 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 19 +-
.../service/ReplicatorTopicPoliciesTest.java | 2 +-
.../pulsar/broker/service/ResendRequestTest.java | 208 +-
.../broker/service/ServerCnxNonInjectionTest.java | 23 +-
.../pulsar/broker/service/ServerCnxTest.java | 25 +-
.../SetReplicationClustersValidationTest.java | 294 +++
.../broker/service/SharedPulsarBaseTest.java | 175 ++
.../pulsar/broker/service/SharedPulsarCluster.java | 211 ++
.../SubscriptionConsumerCompatibilityTest.java | 2 +-
.../broker/service/SubscriptionSeekTest.java | 46 +-
.../broker/service/TopicTerminationTest.java | 60 +-
.../TransactionalReplicateSubscriptionTest.java | 2 +-
.../broker/service/persistent/ChecksumTest.java | 24 +-
.../persistent/CompactionConcurrencyTest.java | 81 +-
.../PartitionKeywordCompatibilityTest.java | 41 +-
...tentDispatcherMultipleConsumersClassicTest.java | 36 +-
.../PersistentDispatcherMultipleConsumersTest.java | 36 +-
...rsistentDispatcherSingleActiveConsumerTest.java | 39 +-
...yKeyDispatcherMultipleConsumersClassicTest.java | 17 +-
.../persistent/PersistentSubscriptionTest.java | 6 +-
.../PersistentTopicProtectedMethodsTest.java | 6 +-
.../service/persistent/PersistentTopicTest.java | 12 +-
.../ReplicatedSubscriptionsControllerTest.java | 168 ++
.../broker/service/persistent/ShadowTopicTest.java | 77 +-
.../schema/JsonSchemaCompatibilityCheckTest.java | 66 +-
.../broker/service/schema/TopicSchemaTest.java | 43 +-
.../schema/validator/SchemaDataValidatorTest.java | 99 +
...RegistryServiceWithSchemaDataValidatorTest.java | 72 +
.../broker/stats/ManagedCursorMetricsTest.java | 16 +-
.../broker/stats/ManagedLedgerMetricsTest.java | 2 +-
.../OpenTelemetryBrokerOperabilityStatsTest.java | 30 +-
.../broker/stats/PrometheusMetricsLabelsTest.java | 271 +++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 259 ++-
.../pulsar/broker/stats/SubscriptionStatsTest.java | 66 +-
.../broker/stats/TransactionMetricsTest.java | 2 +-
.../systopic/PartitionedSystemTopicTest.java | 21 +-
.../SegmentAbortedTxnProcessorTest.java | 6 +-
.../TopicTransactionBufferRecoverTest.java | 6 +-
.../apache/pulsar/broker/web/WebServiceTest.java | 19 +-
.../pulsar/broker/zookeeper/ZKReconnectTest.java | 2 +-
.../api/AuthorizationProducerConsumerTest.java | 4 +-
.../pulsar/client/api/BrokerServiceLookupTest.java | 24 +-
.../org/apache/pulsar/client/api/BytesKeyTest.java | 23 +-
.../client/api/ClientDeduplicationFailureTest.java | 6 +-
.../pulsar/client/api/ClientDeduplicationTest.java | 69 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 66 +-
.../pulsar/client/api/ConsumerAckListTest.java | 26 +-
.../client/api/ConsumerBatchReceiveTest.java | 42 +-
.../pulsar/client/api/ConsumerCleanupTest.java | 29 +-
.../pulsar/client/api/CustomMessageIdTest.java | 23 +-
.../client/api/DispatcherBlockConsumerTest.java | 2 +-
.../api/ExposeMessageRedeliveryCountTest.java | 24 +-
.../client/api/FailoverSubscriptionTest.java | 22 +-
.../apache/pulsar/client/api/InterceptorsTest.java | 101 +-
.../apache/pulsar/client/api/MaxProducerTest.java | 31 +-
.../apache/pulsar/client/api/MemoryLimitTest.java | 22 +-
.../client/api/MessageDispatchThrottlingTest.java | 2 +-
.../client/api/MessageListenerExecutorTest.java | 46 +-
.../pulsar/client/api/MockBrokerService.java | 4 +-
.../pulsar/client/api/MultiTopicsConsumerTest.java | 53 +-
.../api/NonPartitionedTopicExpectedTest.java | 35 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 9 +-
.../api/PartitionedProducerConsumerTest.java | 216 +-
.../client/api/PersistentTopicTerminateTest.java | 30 +-
.../pulsar/client/api/ProducerCleanupTest.java | 23 +-
.../pulsar/client/api/ProducerConsumerBase.java | 4 +-
.../pulsar/client/api/ProducerQueueSizeTest.java | 20 +-
.../pulsar/client/api/ProxyProtocolTest.java | 14 +-
.../client/api/ReplicateSubscriptionTest.java | 27 +-
.../apache/pulsar/client/api/RetryTopicTest.java | 131 +-
.../pulsar/client/api/ServiceUrlProviderTest.java | 79 +-
...roducerConsumerDisallowAutoCreateTopicTest.java | 39 +-
...impleProducerConsumerMLInitializeDelayTest.java | 94 +-
.../client/api/SimpleProducerConsumerStatTest.java | 28 +-
.../api/SimpleTypedProducerConsumerTest.java | 179 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 24 +-
.../org/apache/pulsar/client/api/TlsSniTest.java | 10 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 134 +-
.../client/api/v1/V1ProducerConsumerBase.java | 55 -
.../client/api/v1/V1ProducerConsumerTest.java | 2386 --------------------
.../client/impl/BrokerClientIntegrationTest.java | 10 +-
.../pulsar/client/impl/ClientInterruptTest.java | 4 +
.../client/impl/CompactedOutBatchMessageTest.java | 21 +-
.../pulsar/client/impl/ConnectionHandlerTest.java | 25 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 7 +-
.../client/impl/ConsumeBaseExceptionTest.java | 23 +-
.../apache/pulsar/client/impl/ConsumerAckTest.java | 40 +-
.../pulsar/client/impl/ConsumerCloseTest.java | 26 +-
.../client/impl/ConsumerConfigurationTest.java | 10 +-
.../impl/ConsumerDecryptFailListenerTest.java | 40 +-
.../impl/ConsumerDedupPermitsUpdateTest.java | 22 +-
.../client/impl/ConsumerMemoryLimitTest.java | 21 +-
.../client/impl/DispatchAccordingPermitsTest.java | 21 +-
.../impl/HierarchyTopicAutoCreationTest.java | 33 +-
...eyStoreTlsProducerConsumerTestWithAuthTest.java | 6 +-
...toreTlsProducerConsumerTestWithoutAuthTest.java | 6 +-
.../pulsar/client/impl/LookupServiceTest.java | 67 +-
.../pulsar/client/impl/MessageChecksumTest.java | 79 +-
.../client/impl/MessageChunkingSharedTest.java | 30 +-
.../pulsar/client/impl/MessageChunkingTest.java | 39 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 4 +-
.../apache/pulsar/client/impl/MockMessageTest.java | 23 +-
.../pulsar/client/impl/NegativeAcksTest.java | 43 +-
.../impl/PartialPartitionedProducerTest.java | 31 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 15 +-
.../client/impl/ProduceWithMessageIdTest.java | 16 +-
.../client/impl/ProducerConsumerInternalTest.java | 74 +-
.../pulsar/client/impl/ProducerMemoryLeakTest.java | 39 +-
.../client/impl/ProducerReconnectionTest.java | 25 +-
.../client/impl/PulsarMultiHostClientTest.java | 49 +-
.../apache/pulsar/client/impl/RetryUtilTest.java | 23 +-
.../client/impl/SimpleProduceConsumeIoTest.java | 25 +-
.../apache/pulsar/client/impl/TableViewTest.java | 2 +-
.../pulsar/client/impl/TopicFromMessageTest.java | 42 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 90 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 93 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 94 +-
.../pulsar/client/metrics/ClientMetricsTest.java | 49 +-
.../pulsar/common/naming/NamespaceBundleTest.java | 54 +-
.../pulsar/common/naming/NamespaceBundlesTest.java | 22 +-
.../common/protocol/ProducerBatchSendTest.java | 23 +-
.../pulsar/compaction/CompactedTopicTest.java | 26 +-
.../pulsar/compaction/CompactionRetentionTest.java | 4 +-
.../apache/pulsar/compaction/CompactionTest.java | 19 +-
.../apache/pulsar/compaction/CompactorTest.java | 20 +-
.../compaction/EventTimeOrderCompactorTest.java | 6 +-
.../compaction/GetLastMessageIdCompactedTest.java | 108 +-
.../compaction/ServiceUnitStateCompactionTest.java | 42 +-
.../pulsar/compaction/StrategicCompactionTest.java | 14 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 2 +-
.../worker/PulsarFunctionLocalRunTest.java | 10 +-
.../worker/PulsarFunctionPublishTest.java | 8 +-
.../functions/worker/PulsarFunctionTlsTest.java | 13 +-
.../worker/PulsarWorkerAssignmentTest.java | 4 +-
.../apache/pulsar/io/PulsarBatchSourceE2ETest.java | 2 +-
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 20 +-
.../org/apache/pulsar/io/PulsarSinkE2ETest.java | 6 +-
.../org/apache/pulsar/io/PulsarSourceE2ETest.java | 2 +-
.../apache/pulsar/schema/ExternalSchemaTest.java | 3 +-
.../pulsar/schema/PartitionedTopicSchemaTest.java | 4 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 113 +-
.../stats/client/PulsarBrokerStatsClientTest.java | 31 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 34 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 4 +-
.../proxy/ProxyPublishConsumeTlsTest.java | 4 +-
.../proxy/v1/V1ProxyAuthenticationTest.java | 219 --
pulsar-client-admin-api/pom.xml | 5 +
.../org/apache/pulsar/client/admin/Brokers.java | 17 +-
.../{ProxyStats.java => MetadataMigration.java} | 18 +-
.../org/apache/pulsar/client/admin/Namespaces.java | 108 +-
.../org/apache/pulsar/client/admin/Properties.java | 130 --
.../apache/pulsar/client/admin/PulsarAdmin.java | 9 +-
.../pulsar/common/migration/MigrationPhase.java | 37 +-
.../pulsar/common/migration/MigrationState.java | 28 +-
.../{functions => migration}/package-info.java | 2 +-
.../apache/pulsar/common/naming/TopicVersion.java | 24 -
.../pulsar/common/policies/data/Policies.java | 11 +
.../client/admin/internal/BrokerStatsImpl.java | 6 +-
.../pulsar/client/admin/internal/BrokersImpl.java | 22 +-
.../pulsar/client/admin/internal/LookupImpl.java | 6 +-
...xyStatsImpl.java => MetadataMigrationImpl.java} | 39 +-
.../client/admin/internal/NamespacesImpl.java | 302 ++-
.../admin/internal/NonPersistentTopicsImpl.java | 8 +-
.../client/admin/internal/PulsarAdminImpl.java | 20 +-
.../client/admin/internal/ResourceQuotasImpl.java | 5 +-
.../pulsar/client/admin/internal/SchemasImpl.java | 5 +-
.../pulsar/client/admin/internal/TenantsImpl.java | 31 +-
.../client/admin/internal/TopicPoliciesImpl.java | 5 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 8 +-
.../java/org/apache/pulsar/client/api/Message.java | 2 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 1994 ++++++++--------
.../pulsar/client/cli/PulsarClientToolTest.java | 7 +-
.../pulsar/client/cli/PulsarClientToolWsTest.java | 8 +-
.../org/apache/pulsar/admin/cli/CliCommand.java | 8 -
.../org/apache/pulsar/admin/cli/CmdBrokers.java | 6 +-
.../pulsar/admin/cli/CmdMetadataMigration.java | 67 +
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 95 +-
.../pulsar/admin/cli/CmdPersistentTopics.java | 4 +-
.../apache/pulsar/admin/cli/PulsarAdminTool.java | 2 +
.../org/apache/pulsar/client/cli/CmdConsume.java | 16 +-
.../org/apache/pulsar/client/cli/CmdProduce.java | 14 +-
.../java/org/apache/pulsar/client/cli/CmdRead.java | 15 +-
.../org/apache/pulsar/admin/cli/TestRunMain.java | 2 +-
.../apache/pulsar/client/cli/TestCmdConsume.java | 4 -
.../apache/pulsar/client/cli/TestCmdProduce.java | 3 -
.../org/apache/pulsar/client/cli/TestCmdRead.java | 4 -
.../client/impl/BinaryProtoLookupService.java | 12 +-
.../pulsar/client/impl/ConnectionHandler.java | 4 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 11 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 44 +-
.../pulsar/client/impl/HttpLookupService.java | 12 +-
.../client/impl/MultiTopicsConsumerImpl.java | 4 +-
.../pulsar/client/impl/ProducerBuilderImpl.java | 6 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 46 +-
.../client/impl/PulsarChannelInitializer.java | 12 +-
.../pulsar/client/impl/PulsarClientImpl.java | 13 +-
.../client/impl/PulsarServiceNameResolver.java | 14 +-
.../SameAuthParamsLookupAutoClusterFailover.java | 5 +
.../pulsar/client/impl/TopicListWatcher.java | 15 +-
.../client/impl/TransactionMetaStoreHandler.java | 43 +-
.../auth/oauth2/AuthenticationFactoryOAuth2.java | 51 +-
.../impl/auth/oauth2/AuthenticationOAuth2.java | 252 ++-
.../AuthenticationOAuth2StandardAuthzServer.java | 26 +-
.../impl/auth/oauth2/ClientCredentialsFlow.java | 2 +
.../org/apache/pulsar/client/util/RetryUtil.java | 6 +-
.../pulsar/client/impl/ConnectionTimeoutTest.java | 7 +-
.../pulsar/client/impl/ConsumerImplTest.java | 4 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 11 +
.../client/impl/ProducerBuilderImplTest.java | 20 +
...ameAuthParamsLookupAutoClusterFailoverTest.java | 253 +++
.../impl/auth/oauth2/AuthenticationOAuth2Test.java | 186 +-
.../tutorial/SampleAsyncProducerWithSchema.java | 2 +-
.../client/tutorial/SampleConsumerWithSchema.java | 2 +-
pulsar-common/pom.xml | 2 +-
.../org/apache/pulsar/common/naming/Constants.java | 2 -
.../apache/pulsar/common/naming/NamespaceName.java | 51 +-
.../org/apache/pulsar/common/naming/TopicName.java | 139 +-
.../pulsar/common/policies/data/PolicyName.java | 1 +
.../org/apache/pulsar/common/util/Backoff.java | 226 +-
.../apache/pulsar/common/util/BackoffBuilder.java | 65 -
.../org/apache/pulsar/common/util/FutureUtil.java | 21 +-
.../pulsar/common/util/netty/ChannelFutures.java | 6 +-
.../pulsar/common/util/netty/NettyFutureUtil.java | 10 +-
.../PulsarByteBufAllocatorDefaultTest.java | 36 +
.../pulsar/common/naming/NamespaceNameTest.java | 105 +-
.../apache/pulsar/common/naming/TopicNameTest.java | 185 +-
.../impl/NamespaceIsolationPoliciesTest.java | 16 +-
.../impl/NamespaceIsolationPolicyImplTest.java | 16 +-
.../org/apache/pulsar/common/util/BackoffTest.java | 143 +-
.../common/util/netty/ChannelFuturesTest.java | 12 +-
pulsar-function-go/examples/go.mod | 20 +-
pulsar-function-go/examples/go.sum | 68 +-
pulsar-function-go/go.mod | 20 +-
pulsar-function-go/go.sum | 68 +-
pulsar-function-go/pb/Function.pb.go | 1346 +++++------
pulsar-function-go/pb/InstanceCommunication.pb.go | 716 ++----
.../pb/InstanceCommunication_grpc.pb.go | 293 +++
pulsar-function-go/pb/Request.pb.go | 93 +-
pulsar-function-go/pb/doc.go | 16 +-
pulsar-function-go/pb/generate.sh | 181 +-
pulsar-function-go/pf/instance.go | 6 +-
pulsar-function-go/pf/instanceConf.go | 2 +-
pulsar-function-go/pf/instanceConf_test.go | 4 +-
pulsar-function-go/pf/instanceControlServicer.go | 13 +-
.../pf/instanceControlServicer_test.go | 22 +-
pulsar-io/debezium/core/pom.xml | 32 +-
pulsar-io/kafka-connect-adaptor/pom.xml | 24 +
.../kafka/connect/AbstractKafkaConnectSource.java | 11 +-
.../io/kafka/connect/KafkaConnectSource.java | 15 +
.../kafka/connect/PulsarIOSourceTaskContext.java | 6 +
.../io/kafka/connect/PulsarKafkaSinkContext.java | 6 +
.../kafka/connect/PulsarKafkaSinkTaskContext.java | 6 +
.../io/kafka/connect/KafkaConnectSourceTest.java | 29 +
.../org/apache/pulsar/io/kinesis/KinesisSink.java | 3 +
.../apache/pulsar/io/redis/sink/RedisSinkTest.java | 15 +-
.../pulsar/metadata/api/MetadataCacheConfig.java | 24 +-
.../apache/pulsar/metadata/api/MetadataStore.java | 21 +
.../api/extended/MetadataStoreExtended.java | 28 +
.../bookkeeper/PulsarLedgerIdGenerator.java | 13 +-
.../PulsarLedgerUnderreplicationManager.java | 12 +-
.../bookkeeper/PulsarRegistrationClient.java | 6 +-
.../metadata/cache/impl/MetadataCacheImpl.java | 17 +-
.../coordination/impl/MigrationCoordinator.java | 231 ++
.../coordination/impl/ResourceLockImpl.java | 8 +-
.../metadata/impl/AbstractMetadataStore.java | 59 +-
.../pulsar/metadata/impl/DualMetadataCache.java | 142 ++
.../pulsar/metadata/impl/DualMetadataStore.java | 493 ++++
.../pulsar/metadata/impl/ZKMetadataStore.java | 7 +-
.../metadata/impl/oxia/OxiaMetadataStore.java | 42 +
.../impl/oxia/OxiaMetadataStoreProvider.java | 20 +-
.../tableview/impl/MetadataStoreTableViewImpl.java | 6 +-
.../AuditorPeriodicBookieCheckTest.java | 2 +-
.../replication/AutoRecoveryMainTest.java | 5 +-
.../replication/TestReplicationWorker.java | 4 +-
.../pulsar/metadata/DualMetadataCacheTest.java | 531 +++++
.../pulsar/metadata/DualMetadataStoreTest.java | 453 ++++
.../apache/pulsar/metadata/MetadataCacheTest.java | 74 +-
.../metadata/MetadataStoreSecondaryIndexTest.java | 170 ++
.../apache/pulsar/metadata/MetadataStoreTest.java | 44 +-
.../pulsar/metadata/MigrationCoordinatorTest.java | 301 +++
.../org/apache/pulsar/metadata/ZKSessionTest.java | 8 +-
.../pulsar/proxy/server/ProxyServiceStarter.java | 3 -
.../server/ProxyConnectionThrottlingTest.java | 7 +-
.../server/ProxyEnableHAProxyProtocolTest.java | 3 +-
.../server/ProxyKeyStoreTlsTransportTest.java | 3 +-
.../proxy/server/ProxyKeyStoreTlsWithAuthTest.java | 10 +-
.../server/ProxyKeyStoreTlsWithoutAuthTest.java | 10 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 7 +-
.../pulsar/proxy/server/ProxyMutualTlsTest.java | 7 +-
.../pulsar/proxy/server/ProxyParserTest.java | 26 +-
.../ProxyServiceStarterDisableZeroCopyTest.java | 1 +
.../proxy/server/ProxyServiceStarterTest.java | 7 +-
.../proxy/server/ProxyServiceTlsStarterTest.java | 7 +-
.../apache/pulsar/proxy/server/ProxyStatsTest.java | 11 +-
.../proxy/server/ProxyStuckConnectionTest.java | 3 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 46 +-
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 12 +-
.../server/ProxyWithAuthorizationNegTest.java | 10 +-
.../server/ProxyWithJwtAuthorizationTest.java | 18 +-
.../server/ProxyWithoutServiceDiscoveryTest.java | 6 +-
.../proxy/socket/client/PerformanceClient.java | 3 +-
pulsar-transaction/coordinator/pom.xml | 7 +-
.../src/main/resources/findbugsExclude.xml | 2 +-
.../pulsar/websocket/AbstractWebSocketHandler.java | 35 +-
.../pulsar/websocket/WebSocketConsumerServlet.java | 3 +-
.../pulsar/websocket/WebSocketProducerServlet.java | 3 +-
.../pulsar/websocket/WebSocketReaderServlet.java | 3 +-
.../websocket/admin/WebSocketWebResource.java | 1 -
.../websocket/admin/v1/WebSocketProxyStatsV1.java | 72 -
.../pulsar/websocket/admin/v1/package-info.java | 19 -
.../service/WebSocketProxyConfiguration.java | 3 +
.../websocket/service/WebSocketServiceStarter.java | 10 -
.../websocket/AbstractWebSocketHandlerTest.java | 77 +-
.../pulsar/websocket/WebSocketServiceTest.java | 50 +
.../websocket/admin/WebSocketWebResourceTest.java | 2 +-
src/pulsar-io-gen.sh | 24 +
.../bookkeeper/client/PulsarMockBookKeeper.java | 2 +-
tests/docker-images/latest-version-image/pom.xml | 4 +-
tests/integration/pom.xml | 2 +
.../tests/integration/cli/AdminMultiHostTest.java | 3 +-
.../integration/cli/SchemaUpdateStrategyTest.java | 59 -
.../containers/DebeziumMongoDbContainer.java | 14 +-
.../containers/DebeziumMySQLContainer.java | 3 +-
.../containers/DebeziumPostgreSqlContainer.java | 3 +-
.../integration/containers/PulsarContainer.java | 2 -
.../integration/io/sinks/KafkaSinkTester.java | 14 +-
.../io/sources/AvroKafkaSourceTest.java | 11 +-
.../integration/io/sources/KafkaSourceTester.java | 30 +-
.../debezium/DebeziumMongoDbSourceTester.java | 41 +-
.../debezium/DebeziumMsSqlSourceTester.java | 2 +-
.../debezium/DebeziumMySqlSourceTester.java | 35 +-
.../debezium/DebeziumOracleDbSourceTester.java | 53 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 2 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../offload/jcloud/OffloadIndexBlockV2Builder.java | 2 +-
.../impl/BlobStoreBackedReadHandleImplV2.java | 30 +-
.../impl/BlobStoreManagedLedgerOffloader.java | 25 +-
.../impl/OffloadIndexBlockV2BuilderImpl.java | 2 +-
.../jcloud/impl/OffloadIndexBlockV2Impl.java | 6 +-
...obStoreManagedLedgerOffloaderStreamingTest.java | 101 +-
.../offload/jcloud/impl/MockManagedLedger.java | 6 +-
.../offload/jcloud/impl/OffloadIndexTest.java | 4 +-
.../offload/jcloud/impl/OffloadIndexV2Test.java | 2 +-
585 files changed, 16807 insertions(+), 21435 deletions(-)
create mode 100644 .github/copilot-instructions.md
create mode 100644 pip/pip-457.md
create mode 100644 pip/pip-462.md
create mode 100644 pip/pip-464.md
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/MetadataMigrationBase.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/BrokerStats.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Brokers.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Clusters.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Functions.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Properties.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/ResourceQuotas.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/SchemasResource.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/package-info.java
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/{Brokers.java =>
MetadataMigration.java} (75%)
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v1/TopicLookup.java
delete mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/v1/package-info.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiSchemaJsonValidationTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1AdminApi2Test.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/v1/V1AdminApiTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BatchMessageBrokerRestartTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SetReplicationClustersValidationTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarBaseTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/SharedPulsarCluster.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsControllerTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsLabelsTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1ProducerConsumerBase.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/v1/V1ProducerConsumerTest.java
delete mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/v1/V1ProxyAuthenticationTest.java
copy
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/{ProxyStats.java
=> MetadataMigration.java} (72%)
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Properties.java
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/GetStatsOptions.java
=>
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/migration/MigrationPhase.java
(54%)
copy
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilterDefinition.java
=>
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/migration/MigrationState.java
(60%)
copy pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/{functions
=> migration}/package-info.java (95%)
delete mode 100644
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/naming/TopicVersion.java
copy
pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/{ProxyStatsImpl.java
=> MetadataMigrationImpl.java} (52%)
create mode 100644
pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdMetadataMigration.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailoverTest.java
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/BackoffBuilder.java
create mode 100644 pulsar-function-go/pb/InstanceCommunication_grpc.pb.go
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/MigrationCoordinator.java
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/DualMetadataCache.java
create mode 100644
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/DualMetadataStore.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/DualMetadataCacheTest.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/DualMetadataStoreTest.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MetadataStoreSecondaryIndexTest.java
create mode 100644
pulsar-metadata/src/test/java/org/apache/pulsar/metadata/MigrationCoordinatorTest.java
delete mode 100644
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v1/WebSocketProxyStatsV1.java
delete mode 100644
pulsar-websocket/src/main/java/org/apache/pulsar/websocket/admin/v1/package-info.java
create mode 100644
pulsar-websocket/src/test/java/org/apache/pulsar/websocket/WebSocketServiceTest.java
