9 Pull requests merged by 6 people

• [fix] Avoid negative estimated entry count

  #24055 merged Mar 7, 2025

• [improve][client] PIP-409: support producer configuration for retry/dead letter topic producer

  #24020 merged Mar 6, 2025

• [improve][monitor] Add version=0.0.4 to /metrics content type for Prometheus 3.x compatibility

  #24060 merged Mar 6, 2025

• [fix][client] Copy eventTime to retry letter topic and DLQ messages

  #24059 merged Mar 5, 2025

• [improve][broker] Support showing client ip address in client stats while using reverse proxy

  #23974 merged Mar 5, 2025

• [improve] Upgrade Netty to 4.1.119.Final

  #24049 merged Mar 4, 2025

• [fix][doc] Workaround Go Yaml issue go-yaml/yaml#789 in docker-compose example

  #24040 merged Mar 3, 2025

• [fix][broker] fix delay queue sequence issue.

  #24035 merged Mar 3, 2025

• [fix][broker] Fix missing validation when setting retention policy on topic level

  #24032 merged Mar 3, 2025

10 Pull requests opened by 9 people

• [fix][test] Fix flaky PrometheusMetricsTest.testBrokerMetrics

  #24042 opened Mar 1, 2025

• [improve][broker]Delete unnecessary calls

  #24045 opened Mar 3, 2025

• [fix] Fix UnsupportedOperationException when update topic policies

  #24048 opened Mar 4, 2025

• [fix] Corrected pulsar_storage_size metric to not multiply offloaded storage by the write quorum

  #24054 opened Mar 4, 2025

• [fix][test] Update partitioned topic subscription assertions in IncrementPartitionsTest

  #24056 opened Mar 5, 2025

• [fix][client] Fix building broken batched message when publishing

  #24061 opened Mar 6, 2025

• [fix][broker]Fix failed consumption after loaded up a terminated topic

  #24063 opened Mar 7, 2025

• [improve][broker] Optimize ThresholdShedder with improved boundary checks and parameter reuse

  #24064 opened Mar 7, 2025

• [fix][monitor] Set correct content-type for metrics endpoints in Pulsar for Prometheus 3.x compatibility

  #24065 opened Mar 7, 2025

• [fix][broker] Typo correction: from backlogQuotaDefaultLimitByte to backlogQuotaDefaultLimitBytes

  #24066 opened Mar 8, 2025

5 Issues closed by 4 people

• Support configuring batch message behavior in Java client's DeadLetterPolicy / DLQ feature

  #19463 closed Mar 6, 2025

• [Bug] Java Client : Pulsar Java client should be able to configure compression for message rejection in the DLQ

  #21954 closed Mar 6, 2025

• I/O imbalance across bookies

  #24010 closed Mar 6, 2025

• [Bug] message eventtime is reset to 0 on reconsumeLater

  #24053 closed Mar 5, 2025

• [Doc] REST API doesn't load on Firefox / Chromium

  #23922 closed Mar 4, 2025

7 Issues opened by 7 people

• [Doc] DotPulsar Avro schema support

  #24062 opened Mar 6, 2025

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

  #24057 opened Mar 5, 2025

• [Enhancement] Make Peek Messages API available for non-admin clients

  #24051 opened Mar 4, 2025

• [Improve] Correct the anti-intuitive behavior of `seek` when `startMessageInclusive()` is configured

  #24047 opened Mar 4, 2025

• [Bug] Pulsar Rest API: Getting a 500 concurrent.ExecutionException: SchemaException: Unable to add schema

  #24046 opened Mar 3, 2025

• [Bug] Getting UnsupportedOperationException while setting subscription level dispatch rate policy

  #24043 opened Mar 3, 2025

• Flaky-test: PrometheusMetricsTest.testBrokerMetrics

  #24041 opened Mar 1, 2025

15 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][client] PIP-407 Add newMessage with schema and transactions

  #23942 commented on Mar 6, 2025 • 5 new comments

• [improve][pip] PIP-406: Introduce metrics related to dispatch_throttled_count

  #23945 commented on Mar 7, 2025 • 5 new comments

• [Bug] Deadlock found in branch-3.0

  #24034 commented on Mar 1, 2025 • 0 new comments

• Flaky-test: BatchMessageTest.testBatchMessageDispatchingAccordingToPermits

  #23825 commented on Mar 2, 2025 • 0 new comments

• [Bug] Checkstyle check is not applied to all tests

  #23079 commented on Mar 3, 2025 • 0 new comments

• Make Java Client Authentication Asynchronous

  #19429 commented on Mar 3, 2025 • 0 new comments

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

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

• Please update the rocksdbjni jar to 9.6.1

  #23402 commented on Mar 5, 2025 • 0 new comments

• [Bug] Error while producing messages

  #19269 commented on Mar 5, 2025 • 0 new comments

• Failover subscription sends first message to multiple consumers

  #15189 commented on Mar 7, 2025 • 0 new comments

• [Bug] Broker failing to start with Ledger errors, autoSkipNonRecoverableData set to true not working

  #23890 commented on Mar 7, 2025 • 0 new comments

• [Bug] broker cannot connect the bookie when bookieId set hostname

  #18899 commented on Mar 7, 2025 • 0 new comments

• [feat]PIP-410: Add a metric to track publish buffer usage.

  #23751 commented on Mar 2, 2025 • 0 new comments

• [improve][pip] PIP-404: Introduce per ledger properties

  #23837 commented on Mar 5, 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 1, 2025 • 0 new comments