This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from c2d33cc49ae [fix][broker]fix memory leak, messages lost, incorrect
replication state if using multiple schema versions(auto_produce) (#24178)
new bebc3b0d6a8 Fix checkstyle issue in previous cherry-pick c2d33cc
new b44db02e841 [fix][broker] Unregister non-static metrics collectors
registered in Prometheus default registry (#24257)
new 335da2a8bd3 [fix][test] Fix TestNG BetweenTestClassesListenerAdapter
listener (#24258)
new cfe7ac56d2a [improve][build] Upgrade Gradle Develocity Maven Extension
dependencies (#24260)
new 2cb88c6ffd5 [improve][io][kca] support fully-qualified topic names in
source records (#24248)
new 72def52d987 [fix][test] Fix flaky
ManagedCursorTest.testSkipEntriesWithIndividualDeletedMessages (#24244)
new 6eb7f7bb765 [fix][test] Fix flaky
ManagedCursorTest.testLastActiveAfterResetCursor and disable failing SchemaTest
(#24261)
new 7cc2fe7b673 [improve][ci] Disable detailed console logging for
integration tests in CI (#24266)
new c0850eed7a1 [fix][broker]Fix incorrect priority between topic policies
and global topic policies (#24254)
new 090ff248de4 [fix][misc] Fix ByteBuf leak in SchemaUtils (#24274)
new d8eb65d831f [fix][broker] Fix HashedWheelTimer leak in PulsarService
by stopping it in shutdown (#24275)
new ca02e4c32e0 [fix][test] Fix multiple ByteBuf leaks in tests (#24281)
new 6b762c287a8 [improve][build] Upgrade zstd version from 1.5.2-3 to
1.5.7-3 (#24263)
new e5d309c0fb6 [cleanup][test] Remove unused parameter from
deleteNamespaceWithRetry method in MockedPulsarServiceBaseTest (#24283)
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/pulsar-ci.yaml | 7 +-
.mvn/extensions.xml | 4 +-
build/run_integration_group.sh | 2 +-
buildtools/pom.xml | 2 +
.../tests/BetweenTestClassesListenerAdapter.java | 90 +++--
.../tests/FastThreadLocalCleanupListener.java | 3 +-
.../pulsar/tests/MockitoCleanupListener.java | 3 +-
.../pulsar/tests/SingletonCleanerListener.java | 3 +-
.../pulsar/tests/ThreadLeakDetectorListener.java | 17 +-
.../BetweenTestClassesListenerAdapterTest.java | 392 +++++++++++++++++++++
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 2 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 39 +-
pom.xml | 5 +-
.../org/apache/pulsar/broker/PulsarService.java | 3 +
.../pulsar/broker/service/AbstractTopic.java | 63 ++--
.../pulsar/broker/service/BrokerService.java | 4 +
.../apache/pulsar/broker/service/ServerCnx.java | 5 +
.../stats/prometheus/metrics/ObserverGauge.java | 19 +-
.../apache/pulsar/broker/admin/AdminApi2Test.java | 3 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 170 +++++++++
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 3 +-
.../broker/auth/MockedPulsarServiceBaseTest.java | 25 +-
.../ManagedLedgerInterceptorImplTest.java | 8 +-
.../broker/service/AbstractBaseDispatcherTest.java | 17 +-
.../broker/service/BacklogQuotaManagerTest.java | 9 +-
.../broker/service/OneWayReplicatorTest.java | 5 +-
.../service/PersistentMessageFinderTest.java | 6 +-
.../pulsar/broker/service/PersistentTopicTest.java | 17 +-
.../pulsar/broker/service/ServerCnxTest.java | 59 +++-
.../broker/service/SharedConsumerAssignorTest.java | 25 +-
.../service/persistent/MessageDuplicationTest.java | 27 +-
...ReplicatedSubscriptionsSnapshotBuilderTest.java | 39 +-
.../broker/transaction/TransactionTestBase.java | 10 +-
.../java/org/apache/pulsar/schema/SchemaTest.java | 3 +-
.../pulsar/client/impl/schema/SchemaUtils.java | 1 +
.../common/policies/data/PolicyHierarchyValue.java | 16 +-
.../pulsar/common/compression/CommandsTest.java | 3 +-
.../common/compression/CompressorCodecTest.java | 2 +
.../policies/data/PolicyHierarchyValueTest.java | 4 +-
.../pulsar/common/protocol/CommandUtilsTests.java | 21 +-
.../apache/pulsar/common/protocol/MarkersTest.java | 6 +
.../kafka/connect/AbstractKafkaConnectSource.java | 13 +-
.../io/kafka/connect/KafkaConnectSourceTest.java | 43 +++
43 files changed, 1024 insertions(+), 174 deletions(-)
create mode 100644
buildtools/src/test/java/org/apache/pulsar/tests/BetweenTestClassesListenerAdapterTest.java
