This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch pulsarbot
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from b3f6ded0c39 Apply suggestions from code review
add 60acfba3aec [fix][test] Stabilize testMsgDropStat by reliably
triggering non-persistent publisher drop (#24929)
add d871e4b74f6 [feat][io] Add ScyllaDB tests (#24931)
add 928cae2522a [improve][broker] Optimize lookup result warn log (#24942)
add 6cdd110f6cc [fix][broker] Fix bug in PersistentMessageExpiryMonitor
which blocked further expirations (#24941)
add 676ba078de5 [fix][sec] Override nimbus-jose-jwt to remediate
CVE-2023-52428 and CVE-2025-53864 (#24937)
add 3983ff012db [fix][admin] Set local policies overwrites "number of
bundles" passed during namespace creation (#24762)
add e557b00dc5e [improve][broker] Don't log an error when
updatePartitionedTopic is called on a non-partitioned topic (#24943)
add d186946f6f3 [feat][client] PIP-234: Support shared resources in
PulsarAdmin to reduce thread usage (#24893)
add a1ed5c4a260 [improve][broker] Add tests for using absolute FQDN for
advertisedAddress and remove extra dot from brokerId (#24787)
add b7582837fdd [fix][monitor] Fix the incorrect metrics name (#21981)
add 344905f136a [fix][broker] Avoid recursive update in ConcurrentHashMap
during policy cache cleanup (#24939)
add c4f125cfa29 [fix][txn] fix concurrent error cause txn stuck in
TransactionBufferHandlerImpl#endTxn (#23551)
add ea53dbba776 [improve][test] Disable flaky
PatternConsumerBackPressureTest until the problem is fixed (#24948)
add a3047a83d60 [fix][sec] Upgrade hadoop3 version from 3.4.0 to 3.4.1
(#24950)
add d168ab8ada8 [fix][broker] Trigger topic creation event only once for
non-existent topic (#24802)
add 39aeec5ad61 [fix][sec] Added Exclusions for tomcat-embed-core and
derby and override mina-core to remediate CVEs (#24949)
add 7c343d0209a [fix][test] Fix flaky
NonPersistentTopicTest.testProducerRateLimit (#24951)
add 34b3654841d [fix][sec] Update Hbase version to 2.6.3-hadoop3 and
exclude Avro from hbase-client to remediate CVEs (#24953)
add 186b503579f [fix][broker] AvgShedder comparison error (#24954)
add d9a36b22ee2 [cleanup][broker] Remove unused configuration
maxMessageSizeCheckIntervalInSeconds (#24958)
add 9944ab0ef5f [improve][fn] Use PulsarByteBufAllocator.DEFAULT instead
of ByteBufAllocator.DEFAULT (#24952)
add 3aaf34576f1 [feat] PIP-442: Add memory limits for
CommandGetTopicsOfNamespace (#24833)
add 0896c0a5fe2 [fix][test] Fix invalid test
NonPersistentTopicTest.testProducerRateLimit (#24957)
add aeb1bd1bf9a [fix][test] Fix flaky
KeySharedSubscriptionBrokerCacheTest.testReplayQueueReadsGettingCached (#24955)
add f29ca21976d [fix][broker]Transactional messages can never be sent
successfully if concurrently taking transaction buffer snapshot (#24945)
add 0cdab922230 [fix][client] Fix deduplication for
getPartitionedTopicMetadata to include method parameters (#24965)
add 8f357b0e4d2 [fix][test] Fixed Nondeterministic Ordering in
SchemaInfoTest (#24969)
add 560ed266101 [fix][test] Fixed Nondeterministic Ordering in Generated
Docs Topics (#24973)
add b789d825feb [feat][client] oauth2 trustcerts file and timeouts (#24944)
add 246325416fc [fix][test] Fixed ResponseBody Check in Test Helper
(#24872)
add bd9d81ddd71 [fix][test] Add Delta Tolerance in Double-Precision
Assertions to Fix Rounding Flakiness (#24972)
add 190273590e6 [improve][client] Deduplicate getTopicsUnderNamespace in
BinaryProtoLookupService (#24962)
add b8d0f142567 [fix][test] Made ProtobufNativeSchemaTest.testSchema
order-independent (#24805)
add 4bf335a3617 [fix][test] Fixed nondeterministic ordering in
MongoSourceTest.testWriteBadMessage (#24835)
add 27ce9551c1a [fix][broker]Leaving orphan schemas and topic-level
policies after partitioned topic is deleted by GC (#24971)
add 2bf095d6eb9 [fix][test] Fixed Non-Guaranteed Order in
PoliciesDataTest.propertyAdmin (#24871)
add 6fdb4b95b75 [feat][meta] upgrade oxia version to 0.7.2 (#24976)
add 2c9fc9400a7 [fix][build] Remove Confluent and Restlet maven
repositories from top level pom.xml (#24981)
add 15e198a751c [improve] Upgrade Caffeine to 3.2.3 (#24984)
add 8b28f421620 [improve] Upgrade Log4j2 to 2.25.2 and slf4j to 2.0.17
(#24985)
add ee3e5eaa9f9 [fix] Handle TLS close_notify to avoid
SslClosedEngineException: SSLEngine closed already (#24986)
add ed31d82ccca [fix][broker]Wrong backlog: expected 0 but got 1 (#24938)
add 1555607fa29 [improve][broker]Improve error response of failed to
delete topic if it has replicators connected (#24975)
add 212ee6a2e27 [improve][build] Upgrade Testcontainers to 1.21.3 (#24982)
add 633d19ee31c [fix][sec] Bump github.com/dvsekhvalnov/jose2go from 1.6.0
to 1.7.0 in /pulsar-function-go (#24987)
add b9222ad7da9 [improve][test] Use Oxia project docker container for
integration tests (#24995)
add 8fb418bd445 [improve] Upgrade Apache Commons library versions (#24983)
add 53162ff745f [improve][monitor] Upgrade OpenTelemetry to 1.56.0, Otel
instrumentation to 2.21.0 and Otel semconv to 1.37.0 (#24994)
add 4566edddd62 [fix][broker] Fix creation of replicated subscriptions for
partitioned topics (#24997)
add 807dcaf5d92 [improve][fn] Upgrade Kubernetes client-java version to
23.0.0 and add k8s e2e integration tests (#25000)
add 43f75dfa86f [fix][client] Skip processing messages in the listener
when the consumer has been closed (#25006)
add 9deee37f0b4 [fix][client] PIP-84: Skip processing a message in the
message listener if the consumer epoch is no longer valid (#25007)
add c8d6208bb36 [fix][client] Fix double recycling of the message in
isValidConsumerEpoch method (#25008)
add ec609af4a31 [fix][broker] Fix issue with schemaValidationEnforced in
geo-replication (#25012)
add 67dafa19399 [improve][client] Test no exception could be thrown for
invalid epoch in message (#25013)
add a44e60da13b [fix][broker] Add schema version in rest produce api
(#25004)
add 163f35fd77a [improve] Eliminate unnecessary duplicate schema lookups
for partitioned topics in client and geo-replication (#25011)
add a0637a6c15e [improve][broker]Remove the warn log that frequently
prints (#25018)
add 0fd0701d0dc [fix][client] Fix AutoProduceBytesSchema.clone() method
(#25015)
add d3d5963bdcf [fix][client] Fix thread-safety of AutoProduceBytesSchema
(#25014)
add 684982471cf [fix] Upgrade gson to 2.13.2 (#25022)
add 3937788d9bb [fix][broker]Fix memory leak when using a customized
ManagedLedger implementation (#25016)
add 081b4489cce [fix][sec] Eliminate commons-collections dependency
(#25024)
add 3571e244e17 [improve][broker]Add test for getting partitioned topic
metadata with PulsarAdmin client (#25026)
add d3cb504b902 [improve][io] Upgrade Debezium version to 3.2.5.Final
(#25029)
add a8b41b95ec9 [improve][misc] Add log4j-layout-template-json to server
distribution to enable e.g. ECS template support in log4j configurations for
Pulsar server components. (#25027)
add a272c5b76a0 [improve] [broker] Add overrideBrokerNics for adaptation
of heterogeneous network environments (#24883)
add b37b5b3fa01 [improve][client] Deduplicate in-progress lookup requests
also for HttpLookupService (#25017)
add b71bea4c423 [fix][test] Replace LZ4FastDecompressor with
LZ4SafeDecompressor in test (#25032)
add 909efec5f65 [improve][meta] Add byte size limit to
AbstractMetadataStore's childrenCache (#24868)
add dcb8070ea81 [cleanup][client] Remove unnecessary pause/resume logic
from MultiTopicsConsumerImpl and cleanup putIfAbsent logic (#25009)
add 2c840ba0c82 [improve][misc]introduce log4j Console appender
ConsoleJson (#25034)
add 9cbfc1de1df [fix][broker]Incorrect backlog that is larger than
expected (#25037)
add 6903b291e17 [improve][client] Add null checks for MessageAcknowledger
methods to prevent NullPointerException (#25036)
add 9d8bf601749 [fix][client] Fix lookup request semaphore not release
problem (#25038)
add 5356b64770f [fix][broker] Fix potential NPE in
InMemTransactionBuffer.appendBufferToTxn by returning a valid Position (#25039)
add 270120ce6e3 [improve][misc] Upgrade jjwt library version to 0.13.0
(#25043)
add 89f60158971 [improve][broker] Fix replicated subscriptions race
condition with mark delete update and snapshot completion (#16651)
add 3902b09a846 [fix][sec] Bump at.yawk.lz4:lz4-java from 1.9.0 to 1.10.1
in /pulsar-common (#25045)
add b3c51485d1a [fix][cli] Fix some pulsar-admin topicPolicies commands
exiting before async operations complete (#25051)
add 02445364630 [fix][cli] Fix output of --print-metadata in cli consume
(#25056)
add d2a45e76a85 [improve][build] Upgrade errorprone to 2.45.0 version
(#25054)
add 39ea19e41d6 [fix][broker] Fix various error-prone detected errors
mainly in logging and String.format parameters (#25059)
add 47b8d5d86f1 [fix][broker] fix prepareInitPoliciesCacheAsync in
SystemTopicBasedTopicPoliciesService (#24980)
add 4e5364fa7e5 [fix][admin] Refactor bookie affinity group sync
operations to async in rest api (#25050)
add 76a2394022b [fix][broker] Force EnsemblePolicies to resolve network
location after rackInfoMap is updated due to changes in /ledgers/available
znode (#25067)
add 63450269932 [improve][broker] Improve replicated subscription snapshot
cache so that subscriptions can be replicated when mark delete position update
is not frequent (#25044)
add c8dbc3c9c22 [fix][broker] PIP-442: Fix race condition in async
semaphore permit updates that causes memory limits to become ineffective
(#25066)
add f9bb2e45afd [fix][client] Fix invalid parameter type passed to Map.get
in TopicsImpl.getListAsync method (#25069)
add 9937d22ffea [improve][broker] Use atomic counter for ongoing
transaction count (#25053)
add 81aff30c4b4 [fix][broker]Fix incorrect backlog if use multiple
acknowledge types on the same subscription (#25047)
add c572e82c7a0 [fix][broker]Infinitely failed to delete topic if the
first time failed and enabled transaction (#25073)
add b94a4bb7884 [fix][ci] Fix .github/actions/ssh-access which is used for
debugging Pulsar CI in forks (#25075)
add 3efc174f42d [fix][sec] Upgrade Netty to 4.1.130.Final (#25078)
add 5096faa40ce [cleanup][io] Remove Pulsar IO Flume connector (#25079)
add 82ab144e6d3 [cleanup][io] Remove Pulsar IO Twitter connector (#25080)
add 611a3a43a6c [fix][build] Activate jdk21 and jdk24 profiles on Java 25
(#25084)
add d80401faba3 [improve][io] Replace Qpid in tests with RabbitMQ in
Testcontainers and upgrade RabbitMQ client version (#25085)
add 26297ac77c0 [fix][broker] Fix cursor position persistence in ledger
trimming (#25087)
add e041fab73c1 [fix][admin] Refactor namespace anti affinity group sync
operations to async in rest api (#25086)
add 621b41f5067 [fix][ci] Move flaky asyncMarkDeleteBlocking tests to
flaky group (#25096)
add 3fb52c5d749 [fix][sec] Upgrade jose4j to 0.9.6 to address
CVE-2024-29371 (#25095)
add 449552534c1 [fix][sec] Upgrade log4j to 2.25.3 to address
CVE-2025-68161 (#25102)
add fbab357fdc2 [fix][broker]pulsar_ml_reads_inflight_bytes and
pulsar_ml_reads_available_inflight_bytes are 0 at the same time (#25105)
add 9c5e1c310e2 [fix][test] Fix ManagedCursorTest and NonDurableCursorTest
flaky tests (#25101)
add ab65faa12ab [fix][client]Producer stuck or geo-replication stuck due
to wrong value of message.numMessagesInBatch (#25106)
add ff0d0eb2ba9 [fix][test] Fix flaky PulsarFunctionsK8STest (#25108)
add df89b60518d [fix][broker] Fix chunked message loss when no consumers
are available (#25077)
add 75658cc353e [improve][admin] Add counter for marker messages in
PersistentTopics.analyzeSubscriptionBacklog() rest api (#25091)
add 793e9472eeb [fix][ml] Fix cursor backlog size to account for
individual acks (#25089)
add 133fe203c54 [fix][broker] Fix MultiRolesTokenAuthorizationProvider
error when subscription prefix doesn't match. (#25121)
add 8864e2d6865 [feat][pip] PIP-447: Customizable Prometheus Labels for
Topic Metrics (#24862)
add af6c2dd13c5 [feat][pip] PIP-446: Support Native OpenTelemetry Tracing
in Pulsar Java Client (#24857)
add 68d377937bc [improve][broker] Fix thread safety issue in
ManagedCursorImpl.removeProperty (#25104)
add 3e6133ee014 [fix][broker] fix flaky test in
SystemTopicBasedTopicPoliciesServiceTest (#25098)
add f1018117335 [fix][broker] Fix compaction horizon might be reset to an
old position when phase two is interrupted (#25119)
add b1019ce54dd [improve][broker] Enhance logging for adding schema
failures in ServerCnx (#25048)
add bf98773a2d3 [fix][admin] Fix asyncGetRequest to handle 204 (#25124)
add b4b05b530dc [fix][broker]Topic deleting failed after removed local
cluster from namespace policies (#25114)
add 40953cbeafa [fix][test] Wait for txn.abort() to complete to avoid
AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker()
flaky test (#25125)
add d72dc04549b [improve][broker] Change the log level from error to info
when throwing NotAllowedException (#25130)
add 1617bb22173 [fix][broker] Fix markDeletedPosition race condition in
ManagedLedgerImpl.maybeUpdateCursorBeforeTrimmingConsumedLedger() method
(#25110)
add 1fcdf8bb9a9 [fix][broker] Fix regex matching of namespace name which
might contain a regex char (#25136)
add 1708933303a [improve][pip] PIP-439: Adding Transaction Support to
Pulsar Functions Through Managed Transaction Wrapping (#24704)
add 38807b1511b [fix][broker] Avoid split non-existent bundle (#25031)
add 7ecd9f33b81 Merge remote-tracking branch 'origin/master' into pulsarbot
add 40def194410 remove unnecessary runsAtHeadRaw
add 8043b76368b Revert change to remove license header
No new revisions were added by this update.
Summary of changes:
.github/actions/ssh-access/action.yml | 36 +-
.github/workflows/ci-pulsarbot.yaml | 24 +-
.github/workflows/pulsar-ci.yaml | 7 +-
bin/bookkeeper | 2 +
bin/pulsar | 2 +
bin/pulsar-admin-common.cmd | 2 +
bin/pulsar-admin-common.sh | 2 +
bin/pulsar-perf | 2 +
build/build_java_test_image.sh | 2 +-
build/run_integration_group.sh | 4 +
buildtools/pom.xml | 8 +-
.../src/main/resources/pulsar/suppressions.xml | 6 -
conf/broker.conf | 30 +-
conf/log4j2.yaml | 14 +-
conf/proxy.conf | 24 +
conf/standalone.conf | 28 +-
deployment/terraform-ansible/deploy-pulsar.yaml | 2 -
deployment/terraform-ansible/templates/broker.conf | 4 -
distribution/io/src/assemble/io.xml | 2 -
distribution/server/pom.xml | 5 +
distribution/server/src/assemble/LICENSE.bin.txt | 160 +--
distribution/shell/src/assemble/LICENSE.bin.txt | 70 +-
docker/README.md | 4 +-
grafana/dashboards/bookkeeper.json | 8 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 262 +++--
.../mledger/impl/ManagedLedgerFactoryImpl.java | 17 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 157 ++-
.../mledger/impl/NonDurableCursorImpl.java | 17 +-
.../mledger/impl/cache/InflightReadsLimiter.java | 7 +-
.../mledger/impl/ManagedCursorListAckTest.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 408 ++++++-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 563 ++++++++++
.../mledger/impl/NonDurableCursorTest.java | 10 +-
.../impl/cache/InflightReadsLimiterTest.java | 12 +
.../mledger/util/ManagedLedgerTestUtil.java | 54 +
pip/pip-439.md | 413 +++++++
pip/pip-442.md | 600 +++++++----
pip/pip-446.md | 524 +++++++++
pip/pip-447.md | 230 ++++
pom.xml | 132 ++-
pulsar-bom/pom.xml | 10 -
pulsar-broker-auth-oidc/pom.xml | 4 -
.../broker/authentication/oidc/JwksCache.java | 2 +-
.../oidc/OpenIDProviderMetadataCache.java | 2 +-
...uthenticationProviderOpenIDIntegrationTest.java | 6 +-
.../rackawareness/BookieRackAffinityMapping.java | 26 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 44 +-
.../AuthenticationProviderToken.java | 27 +-
.../MultiRolesTokenAuthorizationProvider.java | 61 +-
.../broker/resources/LocalPoliciesResources.java | 11 +-
.../pulsar/broker/resources/TopicResources.java | 4 +-
.../topiclistlimit/TopicListMemoryLimiter.java | 312 ++++++
.../topiclistlimit/TopicListSizeResultCache.java | 122 +++
.../topiclistlimit}/package-info.java | 4 +-
.../BookieRackAffinityMappingTest.java | 143 ++-
.../AuthenticationProviderTokenTest.java | 12 +-
.../MultiRolesTokenAuthorizationProviderTest.java | 117 +-
.../broker/resources/TopicResourcesTest.java | 11 +
.../stats/prometheus/PrometheusMetricsClient.java | 2 +
.../TopicListSizeResultCacheTest.java | 321 ++++++
.../pulsar/broker/ManagedLedgerClientFactory.java | 3 +-
.../org/apache/pulsar/broker/PulsarService.java | 14 +-
.../apache/pulsar/broker/admin/AdminResource.java | 17 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 341 +++---
.../broker/admin/impl/PersistentTopicsBase.java | 6 +-
.../apache/pulsar/broker/admin/v1/Namespaces.java | 98 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 103 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 2 +-
.../extensions/scheduler/SplitScheduler.java | 2 +-
.../DefaultNamespaceBundleSplitStrategyImpl.java | 2 +-
.../pulsar/broker/loadbalance/impl/AvgShedder.java | 3 +-
.../loadbalance/impl/LinuxBrokerHostUsageImpl.java | 6 +-
.../loadbalance/impl/ModularLoadManagerImpl.java | 21 +-
.../pulsar/broker/lookup/TopicLookupBase.java | 4 +
.../org/apache/pulsar/broker/rest/TopicsBase.java | 7 +-
.../broker/service/AnalyzeBacklogResult.java | 1 +
.../pulsar/broker/service/BrokerService.java | 33 +-
.../pulsar/broker/service/PulsarCommandSender.java | 7 +-
.../broker/service/PulsarCommandSenderImpl.java | 18 +-
.../service/PulsarMetadataEventSynchronizer.java | 8 +-
.../apache/pulsar/broker/service/ServerCnx.java | 153 ++-
.../broker/service/SharedConsumerAssignor.java | 10 +-
.../SystemTopicBasedTopicPoliciesService.java | 75 +-
.../persistent/GeoPersistentReplicator.java | 2 +-
.../PersistentDispatcherMultipleConsumers.java | 2 +-
...rsistentDispatcherMultipleConsumersClassic.java | 2 +-
.../persistent/PersistentMessageExpiryMonitor.java | 1 +
.../service/persistent/PersistentReplicator.java | 5 +-
.../service/persistent/PersistentSubscription.java | 70 +-
.../broker/service/persistent/PersistentTopic.java | 109 +-
.../ReplicatedSubscriptionSnapshotCache.java | 351 +++++-
.../ReplicatedSubscriptionsController.java | 27 +-
.../stats/prometheus/NamespaceStatsAggregator.java | 3 +-
.../pulsar/broker/tools/LoadReportCommand.java | 3 +-
.../transaction/buffer/TransactionBuffer.java | 5 +
.../buffer/impl/InMemTransactionBuffer.java | 12 +-
.../buffer/impl/TopicTransactionBuffer.java | 205 +++-
.../buffer/impl/TopicTransactionBufferState.java | 30 +-
.../buffer/impl/TransactionBufferDisable.java | 5 +
.../buffer/impl/TransactionBufferHandlerImpl.java | 4 +
.../pulsar/common/naming/NamespaceBundles.java | 2 +-
.../compaction/AbstractTwoPhaseCompactor.java | 6 +-
.../pulsar/utils/auth/tokens/TokensCliUtils.java | 4 +-
.../CustomizedManagedLedgerStorageForTest.java | 1128 ++++++++++++++++++++
.../mledger/impl/CustomizedManagedLedgerTest.java | 116 ++
.../PersistentMessageExpiryMonitorMockTest.java | 129 +++
.../org/apache/pulsar/broker/BrokerTestUtil.java | 12 +-
...tatTest.java => PulsarServiceBrokerIdTest.java} | 29 +-
.../pulsar/broker/TopicEventsListenerTest.java | 83 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 48 +-
.../admin/AnalyzeBacklogSubscriptionTest.java | 1 +
.../broker/admin/GetPartitionMetadataTest.java | 65 ++
.../apache/pulsar/broker/admin/NamespacesTest.java | 114 ++
.../pulsar/broker/admin/NamespacesV2Test.java | 261 +++++
.../org/apache/pulsar/broker/admin/TopicsTest.java | 63 ++
.../broker/admin/v3/AdminApiTransactionTest.java | 89 ++
.../broker/auth/MockedPulsarServiceBaseTest.java | 6 +-
.../extensions/scheduler/TransferShedderTest.java | 137 +--
.../impl/LinuxBrokerHostUsageImplTest.java | 40 +-
.../impl/ModularLoadManagerImplTest.java | 54 +
.../broker/service/MessageCumulativeAckTest.java | 4 +-
...eWayReplicatorSchemaValidationEnforcedTest.java | 103 ++
.../broker/service/OneWayReplicatorTest.java | 31 +
...OneWayReplicatorUsingGlobalPartitionedTest.java | 5 +
.../service/OneWayReplicatorUsingGlobalZKTest.java | 7 +-
.../PersistentDispatcherFailoverConsumerTest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 14 +-
.../broker/service/ReplicatedSubscriptionTest.java | 41 +-
.../ReplicationTopicGcUsingGlobalZKTest.java | 5 -
.../pulsar/broker/service/ReplicatorTestBase.java | 2 +-
.../pulsar/broker/service/ServerCnxTest.java | 3 +
.../broker/service/SharedConsumerAssignorTest.java | 58 +-
.../SystemTopicBasedTopicPoliciesServiceTest.java | 210 ++++
.../TransactionMetadataStoreServiceTest.java | 47 +-
.../ReplicatedSubscriptionSnapshotCacheTest.java | 241 ++++-
.../broker/service/plugin/FilterEntryTest.java | 11 +-
.../broker/transaction/TransactionConsumeTest.java | 101 ++
.../buffer/TopicTransactionBufferTest.java | 42 +-
.../buffer/utils/TransactionBufferTestImpl.java | 15 +
.../pulsar/client/api/BrokerServiceLookupTest.java | 7 +-
.../client/api/HybridTypesAcknowledgeTest.java | 422 ++++++++
.../pulsar/client/api/MultiTopicsConsumerTest.java | 82 ++
.../pulsar/client/api/NonPersistentTopicTest.java | 94 +-
...ackPressureMultipleConsumersHttpLookupTest.java | 38 +-
...nConsumerBackPressureMultipleConsumersTest.java | 248 +++++
.../api/PatternConsumerBackPressureTest.java | 7 +-
.../client/api/SimpleProducerConsumerTest.java | 113 ++
.../apache/pulsar/client/api/SimpleSchemaTest.java | 6 +-
.../apache/pulsar/client/impl/ConsumerAckTest.java | 46 +
.../apache/pulsar/client/impl/LookupRetryTest.java | 34 +
.../apache/pulsar/client/impl/MockMessageTest.java | 113 ++
.../apache/pulsar/compaction/CompactionTest.java | 140 ++-
.../pulsar/compaction/StrategicCompactionTest.java | 45 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 8 +-
.../org/apache/pulsar/utils/TestLogAppender.java | 113 ++
.../utils/auth/tokens/TokensCliUtilsTest.java | 12 +-
.../pulsar/client/admin/PulsarAdminBuilder.java | 14 +
.../stats/AnalyzeSubscriptionBacklogResult.java | 1 +
pulsar-client-admin-shaded/pom.xml | 1 -
.../pulsar/client/admin/internal/BaseResource.java | 12 +-
.../admin/internal/PulsarAdminBuilderImpl.java | 12 +-
.../client/admin/internal/PulsarAdminImpl.java | 16 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 2 +-
.../admin/internal/http/AsyncHttpConnector.java | 104 +-
.../internal/http/AsyncHttpConnectorProvider.java | 5 +-
.../client/admin/internal/AsyncGetRequestTest.java | 168 +++
.../admin/internal/PulsarAdminBuilderImplTest.java | 96 ++
.../internal/http/AsyncHttpConnectorTest.java | 10 +-
pulsar-client-all/pom.xml | 1 -
.../pulsar/client/api/MessageAcknowledger.java | 47 +
pulsar-client-shaded/pom.xml | 1 -
.../apache/pulsar/admin/cli/CmdTopicPolicies.java | 9 +-
.../pulsar/client/cli/AbstractCmdConsume.java | 4 +-
.../client/impl/BinaryProtoLookupService.java | 77 +-
.../org/apache/pulsar/client/impl/ClientCnx.java | 16 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 72 +-
.../pulsar/client/impl/HttpLookupService.java | 14 +-
...rogressDeduplicationDecoratorLookupService.java | 276 +++++
.../apache/pulsar/client/impl/LookupService.java | 26 +-
.../client/impl/MultiTopicsConsumerImpl.java | 111 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 9 +-
.../pulsar/client/impl/PulsarClientImpl.java | 29 +-
.../auth/oauth2/AuthenticationFactoryOAuth2.java | 154 ++-
.../impl/auth/oauth2/ClientCredentialsFlow.java | 110 +-
.../pulsar/client/impl/auth/oauth2/FlowBase.java | 76 +-
.../oauth2/protocol/DefaultMetadataResolver.java | 95 +-
.../impl/auth/oauth2/protocol/TokenClient.java | 59 +-
.../client/impl/schema/AutoProduceBytesSchema.java | 28 +-
.../pulsar/client/util/ExecutorProvider.java | 12 +-
.../client/impl/BinaryProtoLookupServiceTest.java | 280 +++++
.../oauth2/AuthenticationFactoryOAuth2Test.java | 59 +
.../impl/schema/AutoProduceBytesSchemaTest.java | 78 ++
.../impl/schema/ProtobufNativeSchemaTest.java | 73 +-
.../pulsar/client/impl/schema/SchemaInfoTest.java | 11 +-
pulsar-common/pom.xml | 4 +-
.../apache/pulsar/common/protocol/Commands.java | 17 +-
.../pulsar/common/protocol/PulsarDecoder.java | 24 +
.../common/semaphore/AsyncDualMemoryLimiter.java | 114 ++
.../semaphore/AsyncDualMemoryLimiterImpl.java | 179 ++++
.../semaphore/AsyncDualMemoryLimiterUtil.java | 123 +++
.../pulsar/common/semaphore/AsyncSemaphore.java | 129 +++
.../common/semaphore/AsyncSemaphoreImpl.java | 363 +++++++
.../pulsar/common/semaphore}/package-info.java | 6 +-
.../common/compression/CompressionCodecLZ4JNI.java | 10 +-
.../common/policies/data/PoliciesDataTest.java | 4 +-
.../semaphore/AsyncDualMemoryLimiterImplTest.java | 745 +++++++++++++
.../semaphore/AsyncDualMemoryLimiterUtilTest.java | 581 ++++++++++
.../common/semaphore/AsyncSemaphoreImplTest.java | 669 ++++++++++++
.../apache/pulsar/docs/tools/CmdGenerateDocs.java | 25 +-
.../pulsar/docs/tools/CmdGenerateDocsTest.java | 4 +-
pulsar-function-go/examples/go.mod | 2 +-
pulsar-function-go/examples/go.sum | 4 +-
pulsar-function-go/go.mod | 2 +-
pulsar-function-go/go.sum | 4 +-
.../auth/KubernetesSecretsTokenAuthProvider.java | 19 +-
.../runtime/kubernetes/KubernetesRuntime.java | 100 +-
.../kubernetes/KubernetesRuntimeFactory.java | 6 +-
.../KubernetesSecretsTokenAuthProviderTest.java | 11 +-
.../kubernetes/KubernetesRuntimeFactoryTest.java | 10 +-
.../runtime/kubernetes/KubernetesRuntimeTest.java | 48 +-
pulsar-functions/worker/pom.xml | 25 +-
.../worker/rest/api/FunctionsMetricsResource.java | 4 +-
.../rest/api/v3/AbstractFunctionsResourceTest.java | 19 +-
.../worker/rest/api/v3/SinkApiV3ResourceTest.java | 2 +-
.../rest/api/v3/SourceApiV3ResourceTest.java | 50 +-
.../java/org/apache/pulsar/io/core/PushSource.java | 2 +-
pulsar-io/docs/pom.xml | 10 -
pulsar-io/flume/pom.xml | 165 ---
.../org/apache/pulsar/io/flume/FlumeConfig.java | 72 --
.../org/apache/pulsar/io/flume/FlumeConnector.java | 123 ---
.../flume/node/AbstractConfigurationProvider.java | 558 ----------
.../AbstractZooKeeperConfigurationProvider.java | 102 --
.../apache/pulsar/io/flume/node/Application.java | 237 ----
.../io/flume/node/ConfigurationProvider.java | 23 -
.../io/flume/node/EnvVarResolverProperties.java | 60 --
.../io/flume/node/MaterializedConfiguration.java | 45 -
...PollingPropertiesFileConfigurationProvider.java | 159 ---
.../PollingZooKeeperConfigurationProvider.java | 127 ---
.../node/PropertiesFileConfigurationProvider.java | 221 ----
.../node/SimpleMaterializedConfiguration.java | 76 --
.../node/StaticZooKeeperConfigurationProvider.java | 55 -
.../apache/pulsar/io/flume/node/package-info.java | 19 -
.../org/apache/pulsar/io/flume/package-info.java | 19 -
.../apache/pulsar/io/flume/sink/AbstractSink.java | 79 --
.../apache/pulsar/io/flume/sink/SourceOfFlume.java | 106 --
.../apache/pulsar/io/flume/sink/StringSink.java | 30 -
.../apache/pulsar/io/flume/sink/package-info.java | 19 -
.../io/flume/source/AbstractSinkOfFlume.java | 32 -
.../pulsar/io/flume/source/AbstractSource.java | 130 ---
.../apache/pulsar/io/flume/source/SinkOfFlume.java | 125 ---
.../pulsar/io/flume/source/StringSource.java | 28 -
.../pulsar/io/flume/source/package-info.java | 19 -
.../resources/META-INF/services/pulsar-io.yaml | 23 -
.../src/main/resources/flume/flume-io-sink.yaml | 25 -
.../src/main/resources/flume/flume-io-source.yaml | 25 -
pulsar-io/flume/src/main/resources/flume/sink.conf | 41 -
.../flume/src/main/resources/flume/source.conf | 41 -
.../apache/pulsar/io/flume/AbstractFlumeTest.java | 24 -
.../node/TestAbstractConfigurationProvider.java | 372 -------
...TestAbstractZooKeeperConfigurationProvider.java | 135 ---
.../pulsar/io/flume/node/TestApplication.java | 202 ----
.../flume/node/TestEnvVarResolverProperties.java | 69 --
...PollingPropertiesFileConfigurationProvider.java | 98 --
.../TestPollingZooKeeperConfigurationProvider.java | 93 --
.../TestPropertiesFileConfigurationProvider.java | 106 --
.../TestStaticZooKeeperConfigurationProvider.java | 44 -
.../pulsar/io/flume/sink/StringSinkTest.java | 138 ---
.../pulsar/io/flume/source/StringSourceTest.java | 107 --
.../resources/flume-conf-with-envvars.properties | 35 -
.../flume/src/test/resources/flume-conf.properties | 115 --
.../src/test/resources/flume-conf.properties.2786 | 35 -
pulsar-io/flume/src/test/resources/flume/sink.conf | 41 -
.../flume/src/test/resources/flume/source.conf | 41 -
.../flume/src/test/resources/log4j.properties | 26 -
pulsar-io/hbase/pom.xml | 4 +
.../org/apache/pulsar/io/http/HttpSinkTest.java | 3 +-
pulsar-io/kafka-connect-adaptor/pom.xml | 10 +
pulsar-io/kafka/pom.xml | 10 +
.../apache/pulsar/io/mongodb/MongoSourceTest.java | 10 +-
pulsar-io/pom.xml | 6 +-
pulsar-io/rabbitmq/pom.xml | 19 +-
.../pulsar/io/rabbitmq/RabbitMQBrokerManager.java | 42 +-
.../pulsar/io/rabbitmq/sink/RabbitMQSinkTest.java | 8 +-
.../io/rabbitmq/source/RabbitMQSourceTest.java | 8 +-
pulsar-io/rabbitmq/src/test/resources/qpid.json | 68 --
pulsar-io/twitter/pom.xml | 91 --
.../apache/pulsar/io/twitter/TwitterFireHose.java | 172 ---
.../pulsar/io/twitter/TwitterFireHoseConfig.java | 172 ---
.../apache/pulsar/io/twitter/data/TweetData.java | 130 ---
.../pulsar/io/twitter/data/TwitterRecord.java | 65 --
.../pulsar/io/twitter/data/package-info.java | 19 -
.../twitter/endpoint/SampleStatusesEndpoint.java | 41 -
.../pulsar/io/twitter/endpoint/package-info.java | 19 -
.../org/apache/pulsar/io/twitter/package-info.java | 19 -
.../resources/META-INF/services/pulsar-io.yaml | 23 -
.../io/twitter/TwitterFireHoseConfigTest.java | 108 --
.../twitter/src/test/resources/sourceConfig.yaml | 23 -
.../metadata/impl/AbstractMetadataStore.java | 46 +-
.../pulsar/opentelemetry/OpenTelemetryService.java | 18 +-
.../opentelemetry/OpenTelemetryServiceTest.java | 13 +-
pulsar-proxy/pom.xml | 12 +
.../pulsar/proxy/server/LookupProxyHandler.java | 95 +-
.../pulsar/proxy/server/ProxyConfiguration.java | 36 +
.../apache/pulsar/proxy/server/ProxyService.java | 27 +-
.../InvalidProxyConfigForAuthorizationTest.java | 1 +
.../proxy/server/ProxyLookupThrottlingTest.java | 3 +-
...nConsumerBackPressureMultipleConsumersTest.java | 112 ++
.../server/ProxyWithExtensibleLoadManagerTest.java | 13 +-
.../impl/MLTransactionMetadataStore.java | 27 +-
.../coordinator/impl/MLTransactionLogImplTest.java | 2 +-
.../pulsar/websocket/LookupProtocolTest.java | 29 +-
src/pulsar-io-gen.sh | 2 +
.../bookkeeper/client/PulsarMockBookKeeper.java | 7 +-
.../bookkeeper/client/PulsarMockLedgerHandle.java | 19 +-
.../bookkeeper/client/PulsarMockReadHandle.java | 13 +-
tests/integration/pom.xml | 63 ++
...sandraContainer.java => ScyllaDBContainer.java} | 25 +-
.../functions/k8s/PulsarFunctionsK8STest.java | 191 ++++
.../integration/io/sinks/PulsarSinksTest.java | 10 +
...ndraSinkTester.java => ScyllaDBSinkTester.java} | 50 +-
.../k8s/AbstractPulsarStandaloneK8STest.java | 411 +++++++
.../loadbalance/ExtensibleLoadManagerTest.java | 15 +-
.../tests/integration/oxia/OxiaContainer.java | 2 +-
.../ClientTlsAbsoluteAdvertisedAddressTest.java | 34 +-
.../src/test/resources/pulsar-k8s.xml} | 6 +-
tests/scripts/pre-integ-tests.sh | 1 +
326 files changed, 16376 insertions(+), 7653 deletions(-)
create mode 100644
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/util/ManagedLedgerTestUtil.java
create mode 100644 pip/pip-439.md
create mode 100644 pip/pip-446.md
create mode 100644 pip/pip-447.md
create mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/topiclistlimit/TopicListMemoryLimiter.java
create mode 100644
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/topiclistlimit/TopicListSizeResultCache.java
copy
pulsar-broker-common/src/main/java/org/apache/pulsar/{bookie/rackawareness =>
broker/topiclistlimit}/package-info.java (90%)
create mode 100644
pulsar-broker-common/src/test/java/org/apache/pulsar/broker/topiclistlimit/TopicListSizeResultCacheTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/CustomizedManagedLedgerStorageForTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/CustomizedManagedLedgerTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/bookkeeper/mledger/impl/PersistentMessageExpiryMonitorMockTest.java
copy
pulsar-broker/src/test/java/org/apache/pulsar/broker/{admin/BrokerStatTest.java
=> PulsarServiceBrokerIdTest.java} (61%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorSchemaValidationEnforcedTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/HybridTypesAcknowledgeTest.java
copy
pulsar-io/core/src/test/java/org/apache/pulsar/io/core/BatchPushSourceTest.java
=>
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerBackPressureMultipleConsumersHttpLookupTest.java
(54%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerBackPressureMultipleConsumersTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/MockMessageTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/utils/TestLogAppender.java
create mode 100644
pulsar-client-admin/src/test/java/org/apache/pulsar/client/admin/internal/AsyncGetRequestTest.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/InProgressDeduplicationDecoratorLookupService.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationFactoryOAuth2Test.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/AutoProduceBytesSchemaTest.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore/AsyncDualMemoryLimiter.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore/AsyncDualMemoryLimiterImpl.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore/AsyncDualMemoryLimiterUtil.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore/AsyncSemaphore.java
create mode 100644
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore/AsyncSemaphoreImpl.java
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/anonymizer
=>
pulsar-common/src/main/java/org/apache/pulsar/common/semaphore}/package-info.java
(90%)
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/semaphore/AsyncDualMemoryLimiterImplTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/semaphore/AsyncDualMemoryLimiterUtilTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/semaphore/AsyncSemaphoreImplTest.java
delete mode 100644 pulsar-io/flume/pom.xml
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConfig.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/Application.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/ConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/EnvVarResolverProperties.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/MaterializedConfiguration.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PollingPropertiesFileConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PollingZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/PropertiesFileConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/SimpleMaterializedConfiguration.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/StaticZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/package-info.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/package-info.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/AbstractSink.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/SourceOfFlume.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/package-info.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSinkOfFlume.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/SinkOfFlume.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/StringSource.java
delete mode 100644
pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/package-info.java
delete mode 100644
pulsar-io/flume/src/main/resources/META-INF/services/pulsar-io.yaml
delete mode 100644 pulsar-io/flume/src/main/resources/flume/flume-io-sink.yaml
delete mode 100644
pulsar-io/flume/src/main/resources/flume/flume-io-source.yaml
delete mode 100644 pulsar-io/flume/src/main/resources/flume/sink.conf
delete mode 100644 pulsar-io/flume/src/main/resources/flume/source.conf
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/AbstractFlumeTest.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestAbstractConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestAbstractZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestApplication.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestEnvVarResolverProperties.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestPollingPropertiesFileConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestPollingZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestPropertiesFileConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/node/TestStaticZooKeeperConfigurationProvider.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/sink/StringSinkTest.java
delete mode 100644
pulsar-io/flume/src/test/java/org/apache/pulsar/io/flume/source/StringSourceTest.java
delete mode 100644
pulsar-io/flume/src/test/resources/flume-conf-with-envvars.properties
delete mode 100644 pulsar-io/flume/src/test/resources/flume-conf.properties
delete mode 100755
pulsar-io/flume/src/test/resources/flume-conf.properties.2786
delete mode 100644 pulsar-io/flume/src/test/resources/flume/sink.conf
delete mode 100644 pulsar-io/flume/src/test/resources/flume/source.conf
delete mode 100644 pulsar-io/flume/src/test/resources/log4j.properties
delete mode 100644 pulsar-io/rabbitmq/src/test/resources/qpid.json
delete mode 100644 pulsar-io/twitter/pom.xml
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TweetData.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/TwitterRecord.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data/package-info.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/endpoint/SampleStatusesEndpoint.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/endpoint/package-info.java
delete mode 100644
pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/package-info.java
delete mode 100644
pulsar-io/twitter/src/main/resources/META-INF/services/pulsar-io.yaml
delete mode 100644
pulsar-io/twitter/src/test/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfigTest.java
delete mode 100644 pulsar-io/twitter/src/test/resources/sourceConfig.yaml
create mode 100644
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server/ProxyPatternConsumerBackPressureMultipleConsumersTest.java
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/{CassandraContainer.java
=> ScyllaDBContainer.java} (58%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/functions/k8s/PulsarFunctionsK8STest.java
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/{CassandraSinkTester.java
=> ScyllaDBSinkTester.java} (70%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/k8s/AbstractPulsarStandaloneK8STest.java
copy pulsar-functions/proto/src/main/proto/Request.proto =>
tests/integration/src/test/java/org/apache/pulsar/tests/integration/tls/ClientTlsAbsoluteAdvertisedAddressTest.java
(59%)
copy tests/{bc_2_0_0/src/test/resources/pulsar.xml =>
integration/src/test/resources/pulsar-k8s.xml} (79%)
