Apache Pulsar 3.0.12

2025-05-22

Library updates

[fix][sec] Upgrade Jetty to 9.4.57.v20241219 to mitigate CVE-2024-6763 (#24232)
[improve] Upgrade Netty to 4.1.121.Final (#24214)
[improve] Upgrade pulsar-client-python to 3.7.0 in Docker image (#24302)
[improve][build] Upgrade Lombok to 1.18.38 to support JDK 24 (#24237)

Broker

[fix][broker] Consumer stuck when delete subscription __compaction failed (#23980)
[fix][broker] Fix broker shutdown delay by resolving hanging health checks (#24210)
[fix][broker] Fix ByteBuf memory leak in REST API for publishing messages (#24228)
[fix][broker] Fix compaction service log's wrong condition (#24207)
[fix][broker] Fix HashedWheelTimer leak in PulsarService by stopping it in shutdown (#24275)
[fix][broker] Fix HealthChecker deadlock in shutdown (#24216)
[fix][broker] Fix missing validation when setting retention policy on topic level (#24032)
[fix][broker] Fix potential deadlock when creating partitioned topic (#24313)
[fix][broker] Fix seeking by timestamp can be reset the cursor position to earliest (#23919)
[fix][broker] Fix some problems in calculate totalAvailableBookies in method getExcludedBookiesWithIsolationGroups when some bookies belongs to multiple isolation groups. (#24091)
[fix][broker] Fix tenant creation and update with null value (#24209)
[fix][broker] fix wrong method name checkTopicExists. (#24293)
[fix][broker] Orphan schema after disabled a cluster for a namespace (#24223)
[fix][broker] The feature brokerDeleteInactivePartitionedTopicMetadataEnabled leaves orphan topic policies and topic schemas (#24150)
[fix][broker] Unregister non-static metrics collectors registered in Prometheus default registry (#24257)
[fix][broker]Fix incorrect priority between topic policies and global topic policies (#24254)
[fix][broker]fix memory leak, messages lost, incorrect replication state if using multiple schema versions(auto_produce) (#24178)
[fix][admin] Backlog quota's policy is null which causes a NPE (#24192)
[fix][bk] Fix the var name for IsolationGroups (#21320)
[fix][ml] Fix ML thread blocking issue in internalGetPartitionedStats API (#24167)
[fix][ml] Skip deleting cursor if it was already deleted before calling unsubscribe (#24098)
[improve][broker] Optimize subscription seek (cursor reset) by timestamp (#22792)
[improve][broker]Improve the feature "Optimize subscription seek (cursor reset) by timestamp": search less entries (#24219)

Client

[fix][client] Fix incorrect producer.getPendingQueueSize due to incomplete queue implementation (#24184)
[fix][client] Fix producer publishing getting stuck after message with incompatible schema is discarded (#24282)
[improve][client] validate ClientConfigurationData earlier to avoid resource leaks (#24187)
[improve][client]Improve transaction log when a TXN command timeout (#24230)

Pulsar IO and Pulsar Functions

[fix][io] Fix SyntaxWarning in Pulsar Python functions (#24297)
[improve][io] Add configuration parameter for disabling aggregation for Kinesis Producers (#24289)
[improve][io] support kafka connect transforms and predicates (#24221)
[improve][io] Upgrade Kafka client and compatible Confluent platform version (#24201)
[improve][io][kca] support fully-qualified topic names in source records (#24248)

Others

[cleanup][misc] Add override annotation (#24033)
[fix][misc] Fix ByteBuf leak in SchemaUtils (#24274)
[fix][proxy] Fix incorrect client error when calling get topic metadata (#24181)
[fix][proxy] Propagate client connection feature flags through Pulsar Proxy to Broker (#24158)
[fix][schema] Reject unsupported Avro schema types during schema registration (#24103)

Tests & CI

[fix][build] Ensure that buildtools is Java 8 compatible and fix remaining compatibility issue (#24307)
[fix][test] Fix flaky BatchMessageWithBatchIndexLevelTest.testBatchMessageAck (#24212)
[fix][test] Fix flaky BrokerServiceChaosTest (#24162)
[fix][test] Fix flaky BrokerServiceChaosTest.testFetchPartitionedTopicMetadataWithCacheRefresh (#24161)
[fix][test] Fix flaky ManagedCursorTest.testLastActiveAfterResetCursor and disable failing SchemaTest (#24261)
[fix][test] Fix flaky ManagedCursorTest.testSkipEntriesWithIndividualDeletedMessages (#24244)
[fix][test] Fix invalid test CompactionTest.testDeleteCompactedLedgerWithSlowAck (#24166)
[fix][test] Fix more Netty ByteBuf leaks in tests (#24299)
[fix][test] Fix multiple ByteBuf leaks in tests (#24281)
[fix][test] Fix multiple resource leaks in tests (#24218)
[fix][test] Fix resource leaks in ProxyTest and fix invalid tests (#24204)
[fix][test] Fix TestNG BetweenTestClassesListenerAdapter listener (#24258)
[fix][test] Improve reliability of IncrementPartitionsTest (#24172)
[fix][test] Simplify BetweenTestClassesListenerAdapter and fix issue with BeforeTest/AfterTest annotations (#24304)
[fix][test] Update partitioned topic subscription assertions in IncrementPartitionsTest (#24056)
[fix][test]flaky-test:ManagedLedgerInterceptorImplTest.testManagedLedgerPayloadInputProcessorFailure (#24170)
[improve][test] Use configured session timeout for MockZooKeeper and TestZKServer in PulsarTestContext (#24171)
[improve][build] Upgrade Gradle Develocity Maven Extension dependencies (#24260)
[improve][ci] Disable detailed console logging for integration tests in CI (#24266)
[improve][build] Upgrade SpotBugs to 4.9.x (#24243)
[improve][build] Upgrade to jacoco 0.8.13 (#24240)
[improve][build] Upgrade zstd version from 1.5.2-3 to 1.5.7-3 (#24263)
[cleanup][test] Remove unused parameter from deleteNamespaceWithRetry method in MockedPulsarServiceBaseTest (#24283)