8 Pull requests merged by 6 people

• [fix][client] Pattern subscription regression when broker-side evaluation is disabled

  #24104 merged Mar 24, 2025

• [improve][broker] PIP-406: Introduce metrics related to dispatch throttled events

  #23946 merged Mar 24, 2025

• [fix][test] Move ReplicatorRateLimiterTest to broker test group

  #24101 merged Mar 22, 2025

• [fix][client] Fix consumer leak when thread is interrupted before subscribe completes

  #24100 merged Mar 21, 2025

• [fix][ml] Fix issues in estimateEntryCountBySize

  #24089 merged Mar 20, 2025

• [improve][broker] Optimize message expiration rate repeated update issues

  #24073 merged Mar 19, 2025

• [improve][pip] PIP-292: Enforce token expiration time in the Websockets plugin

  #20953 merged Mar 19, 2025

• [fix][broker] Restore the behavior to dispatch batch messages according to consumer permits

  #24092 merged Mar 19, 2025

13 Pull requests opened by 9 people

• [fix][broker] Fix some problems in calculate totalAvailableBookies in method getExcludedBookiesWithIsolationGroups when some bookies belongs to multiple isolation groups.

  #24091 opened Mar 18, 2025

• [fix] [broker] Fix negative subscription/consumer's unack-messages

  #24096 opened Mar 19, 2025

• [fix] [broker] topics infinitely failed to delete after remove cluster from replicated clusters modifying when using partitioned system topic

  #24097 opened Mar 19, 2025

• [fix][ml]Skip deleting cursor if it already was deleted when calling unsubscribe

  #24098 opened Mar 19, 2025

• [fix][test] Add build-helper-maven-plugin for jetcd-core-shaded

  #24099 opened Mar 20, 2025

• [fix][client] Unify the data size check during compression

  #24102 opened Mar 20, 2025

• [fix][schema]Pulsar does not support avro-union schema, but it allows it to be registered

  #24103 opened Mar 21, 2025

• [improve][pip] PIP-412: Support setting messagePayloadProcessor in Pulsar Functions and Sinks

  #24105 opened Mar 21, 2025

• Add an indicator for the count of expired messages within a cycle

  #24106 opened Mar 21, 2025

• [test] Add validation tests for dispatcherMaxRoundRobinBatchSize

  #24110 opened Mar 22, 2025

• [improve][broker][branch-4.0] PIP-406: Introduce metrics related to dispatch throttled events

  #24111 opened Mar 24, 2025

• [improve][broker] Change topic exists log to warn

  #24116 opened Mar 24, 2025

• [improve][broker]extract getMaxEntriesInThisBatch into a method and add unit test for it

  #24117 opened Mar 24, 2025

3 Issues closed by 1 person

• [Bug] ExtensibleLoadManager's broker registry cannot recover from session expiration / reconnection

  #24057 closed Mar 21, 2025

• [Bug] Pulsar collection classes contain a bug in the hash bucket algorithm implementation when hash key is negative

  #21108 closed Mar 19, 2025

• Flaky-test: BatchMessageTest.testBatchMessageDispatchingAccordingToPermits

  #23825 closed Mar 19, 2025

5 Issues opened by 5 people

• [Bug] The Jetty version in Pulsar contains CVE-2024-6763

  #24114 opened Mar 24, 2025

• [Bug] KoP: brokerIndex Ordering Issues in Ledger Entries Due to Write Failure

  #24109 opened Mar 22, 2025

• [Bug] got wrong numMessagesInQueue when dispatching batch messages according to consumer permits

  #24107 opened Mar 21, 2025

• Add tests for the dispatcherMaxRoundRobinBatchSize config

  #24094 opened Mar 19, 2025

• [Doc] Typo in PulsarAdminBuilder

  #24093 opened Mar 18, 2025

9 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• [improve] PIP-411: Expose Peek Messages API to Non-Admin Clients

  #24088 commented on Mar 19, 2025 • 1 new comment

• [Bug] Kafka Protocol is not working on Pulsar latest releases

  #24085 commented on Mar 18, 2025 • 0 new comments

• [Doc] DotPulsar Avro schema support

  #24062 commented on Mar 18, 2025 • 0 new comments

• [Bug] Topic partition backlog grows after bookies restart when using ExtensibleLoadManagerImpl

  #23908 commented on Mar 20, 2025 • 0 new comments

• [Bug] Permit calculations are mixing individual message and batch message counts, similar issue in documentation

  #23263 commented on Mar 21, 2025 • 0 new comments

• [Bug] PR Checks are failing on branch-3.0

  #24038 commented on Mar 24, 2025 • 0 new comments

• [improve][broker] If there is a deadlock in the service, the probe should return a failure because the service may be unavailable

  #23634 commented on Mar 18, 2025 • 0 new comments

• [fix][misc]: ignore deleted ledger when tear down cluster

  #23831 commented on Mar 24, 2025 • 0 new comments

• [fix][broker][branch-3.0] Backport missed CompactedTopicImpl deadlock fixes #20697 and #20984 to branch 3.0

  #24037 commented on Mar 20, 2025 • 0 new comments