This is an automated email from the ASF dual-hosted git repository.
mattisonchao pushed a change to branch gradle-migration
in repository https://gitbox.apache.org/repos/asf/pulsar.git
discard 4025bee7051 [improve][build] Migrate build system from Maven to Gradle
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 5a78377a778 [improve][build] Migrate build system from Maven to Gradle
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 (4025bee7051)
\
N -- N -- N refs/heads/gradle-migration (5a78377a778)
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 +++
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 +-
conf/bkenv.sh | 3 +-
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 +-
.../mledger/impl/ManagedLedgerFactoryImpl.java | 6 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 37 +-
.../mledger/impl/NullLedgerOffloader.java | 13 +-
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 16 +-
.../mledger/impl/cache/RangeEntryCacheImpl.java | 26 +-
.../mledger/impl/ManagedLedgerBkTest.java | 4 +-
pip/pip-447.md | 55 +-
pip/pip-457.md | 204 ++
.../apache/pulsar/broker/ServiceConfiguration.java | 20 +-
.../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 -
.../apache/pulsar/PulsarClusterMetadataSetup.java | 9 +-
.../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 | 6 +-
.../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 | 3 +-
.../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 | 151 +-
.../broker/admin/v2/NonPersistentTopics.java | 14 +-
.../pulsar/broker/delayed/bucket/Bucket.java | 5 +-
.../channel/ServiceUnitStateChannelImpl.java | 5 +-
...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/BrokerService.java | 49 +-
.../pulsar/broker/service/HealthChecker.java | 26 +-
.../org/apache/pulsar/broker/service/Producer.java | 2 +-
.../service/PulsarMetadataEventSynchronizer.java | 9 +-
.../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 +-
.../service/persistent/PersistentReplicator.java | 9 +-
.../broker/service/persistent/PersistentTopic.java | 84 +-
.../ReplicatedSubscriptionsController.java | 6 +
.../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 +-
.../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 +-
.../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 | 4 -
.../admin/BrokerEndpointsAuthorizationTest.java | 5 +-
.../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 | 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 +-
.../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 | 46 +-
.../channel/ServiceUnitStateChannelTest.java | 2 +-
.../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 | 14 +-
.../broker/service/BrokerBookieIsolationTest.java | 30 +-
.../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 | 8 +-
.../broker/service/ConsumedLedgersTrimTest.java | 110 +-
.../service/CurrentLedgerRolloverIfFullTest.java | 22 +-
...eateTopicToRemoteClusterForReplicationTest.java | 5 +-
.../broker/service/ExclusiveProducerTest.java | 42 +-
.../broker/service/InactiveTopicDeleteTest.java | 28 +-
.../apache/pulsar/broker/service/KeyValueTest.java | 29 +-
.../pulsar/broker/service/NullValueTest.java | 65 +-
.../broker/service/OneWayReplicatorTest.java | 46 +-
.../broker/service/OneWayReplicatorTestBase.java | 19 +-
...OneWayReplicatorUsingGlobalPartitionedTest.java | 7 +-
.../service/OneWayReplicatorUsingGlobalZKTest.java | 16 +-
.../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 +-
.../broker/service/PersistentQueueE2ETest.java | 12 +-
.../service/PersistentTopicConcurrentTest.java | 2 +-
.../broker/service/PersistentTopicE2ETest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 16 +-
.../broker/service/ReplicatedSubscriptionTest.java | 24 +-
.../broker/service/ReplicatorGlobalNSTest.java | 10 +-
.../broker/service/ReplicatorRateLimiterTest.java | 16 +-
.../service/ReplicatorRemoveClusterTest.java | 1 -
.../pulsar/broker/service/ReplicatorTest.java | 35 +-
.../pulsar/broker/service/ReplicatorTestBase.java | 19 +-
.../service/ReplicatorTopicPoliciesTest.java | 2 +-
.../pulsar/broker/service/ResendRequestTest.java | 169 +-
.../pulsar/broker/service/ServerCnxTest.java | 18 +-
.../SetReplicationClustersValidationTest.java | 294 +++
.../broker/service/SharedPulsarBaseTest.java | 175 ++
.../pulsar/broker/service/SharedPulsarCluster.java | 205 ++
.../SubscriptionConsumerCompatibilityTest.java | 2 +-
.../broker/service/SubscriptionSeekTest.java | 42 +-
.../broker/service/TopicTerminationTest.java | 45 +-
.../TransactionalReplicateSubscriptionTest.java | 2 +-
.../broker/service/persistent/ChecksumTest.java | 24 +-
.../PartitionKeywordCompatibilityTest.java | 41 +-
.../persistent/PersistentSubscriptionTest.java | 6 +-
.../PersistentTopicProtectedMethodsTest.java | 6 +-
.../service/persistent/PersistentTopicTest.java | 12 +-
.../ReplicatedSubscriptionsControllerTest.java | 168 ++
.../broker/service/persistent/ShadowTopicTest.java | 61 +-
.../broker/stats/ManagedCursorMetricsTest.java | 16 +-
.../broker/stats/ManagedLedgerMetricsTest.java | 2 +-
.../OpenTelemetryBrokerOperabilityStatsTest.java | 30 +-
.../broker/stats/PrometheusMetricsLabelsTest.java | 271 +++
.../pulsar/broker/stats/PrometheusMetricsTest.java | 259 ++-
.../broker/stats/TransactionMetricsTest.java | 2 +-
.../systopic/PartitionedSystemTopicTest.java | 21 +-
.../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 | 4 +-
.../apache/pulsar/client/api/ClientErrorsTest.java | 66 +-
.../pulsar/client/api/ConsumerAckListTest.java | 26 +-
.../pulsar/client/api/ConsumerCleanupTest.java | 29 +-
.../pulsar/client/api/CustomMessageIdTest.java | 23 +-
.../client/api/DispatcherBlockConsumerTest.java | 2 +-
.../client/api/FailoverSubscriptionTest.java | 22 +-
.../client/api/MessageDispatchThrottlingTest.java | 2 +-
.../pulsar/client/api/MockBrokerService.java | 4 +-
.../api/NonPartitionedTopicExpectedTest.java | 35 +-
.../pulsar/client/api/NonPersistentTopicTest.java | 9 +-
.../client/api/PersistentTopicTerminateTest.java | 24 +-
.../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 +-
.../client/api/SimpleProducerConsumerStatTest.java | 28 +-
.../api/SimpleTypedProducerConsumerTest.java | 34 +-
.../pulsar/client/api/TlsProducerConsumerTest.java | 24 +-
.../org/apache/pulsar/client/api/TlsSniTest.java | 10 +-
.../apache/pulsar/client/api/TopicReaderTest.java | 4 +-
.../client/api/v1/V1ProducerConsumerBase.java | 55 -
.../client/api/v1/V1ProducerConsumerTest.java | 2386 --------------------
.../client/impl/BrokerClientIntegrationTest.java | 10 +-
.../pulsar/client/impl/ConnectionHandlerTest.java | 25 +-
.../pulsar/client/impl/ConnectionPoolTest.java | 7 +-
.../client/impl/ConsumerConfigurationTest.java | 10 +-
...eyStoreTlsProducerConsumerTestWithAuthTest.java | 6 +-
...toreTlsProducerConsumerTestWithoutAuthTest.java | 6 +-
.../pulsar/client/impl/MessageChecksumTest.java | 79 +-
.../pulsar/client/impl/MessageChunkingTest.java | 39 +-
.../apache/pulsar/client/impl/MessageIdTest.java | 4 +-
.../PerMessageUnAcknowledgedRedeliveryTest.java | 15 +-
.../apache/pulsar/client/impl/RetryUtilTest.java | 23 +-
.../apache/pulsar/client/impl/TableViewTest.java | 2 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 90 +-
.../impl/UnAcknowledgedMessagesTimeoutTest.java | 93 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 94 +-
.../pulsar/common/naming/NamespaceBundleTest.java | 54 +-
.../pulsar/common/naming/NamespaceBundlesTest.java | 22 +-
.../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/ServiceUnitStateCompactionTest.java | 42 +-
.../pulsar/compaction/StrategicCompactionTest.java | 14 +-
.../worker/PulsarFunctionE2ESecurityTest.java | 2 +-
.../worker/PulsarFunctionLocalRunTest.java | 10 +-
.../worker/PulsarFunctionPublishTest.java | 8 +-
.../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 | 98 -
.../stats/client/PulsarBrokerStatsClientTest.java | 2 +-
.../websocket/proxy/ProxyAuthorizationTest.java | 34 +-
.../websocket/proxy/ProxyPublishConsumeTest.java | 4 +-
.../proxy/ProxyPublishConsumeTlsTest.java | 4 +-
.../proxy/v1/V1ProxyAuthenticationTest.java | 219 --
.../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 | 43 +-
.../client/impl/PulsarChannelInitializer.java | 12 +-
.../pulsar/client/impl/PulsarClientImpl.java | 13 +-
.../client/impl/PulsarServiceNameResolver.java | 14 +-
.../pulsar/client/impl/TopicListWatcher.java | 15 +-
.../client/impl/TransactionMetaStoreHandler.java | 43 +-
.../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 +
.../tutorial/SampleAsyncProducerWithSchema.java | 2 +-
.../client/tutorial/SampleConsumerWithSchema.java | 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 +-
.../kafka/connect/AbstractKafkaConnectSource.java | 5 +-
.../io/kafka/connect/KafkaConnectSource.java | 15 +
.../io/kafka/connect/KafkaConnectSourceTest.java | 29 +
.../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 | 58 +-
.../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 | 12 +-
.../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/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 +
.../tests/integration/cli/AdminMultiHostTest.java | 3 +-
.../integration/cli/SchemaUpdateStrategyTest.java | 59 -
.../integration/containers/PulsarContainer.java | 2 -
.../debezium/DebeziumOracleDbSourceTester.java | 51 +-
.../loadbalance/ExtensibleLoadManagerTest.java | 2 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../integration/SimpleProducerConsumerTest.java | 16 +-
.../impl/BlobStoreBackedReadHandleImplV2.java | 30 +-
405 files changed, 10948 insertions(+), 16619 deletions(-)
create mode 100644 .github/copilot-instructions.md
create mode 100644 pip/pip-457.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
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
delete mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/util/BackoffBuilder.java
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
