Google Git
Sign in
apache/pulsar/HEAD
  1. a107d51 [fix][broker] Fix delayed-delivery bucket merge failures when delayedDeliveryMaxNumBuckets is 1-3 (#26242) by void-ptr974 · 2 days ago master
  2. ac4cda7 [fix][client] Avoid exception in ConsumerImpl hasMessageAvailable before first receive (#25857) by void-ptr974 · 4 days ago
  3. bbd1970 [fix][sec] Upgrade lz4-java to 1.11.1 to address CVE-2026-59949 (#26250) by Lari Hotari · 4 days ago
  4. 6a109ac [fix][test] Fix flaky AdminApiTest caused by leaked brokerShutdownTimeoutMs (#26249) by Lari Hotari · 4 days ago
  5. d54d83d [fix][ml] Tolerate concurrent creation of the managed ledger z-node (#26247) by Lari Hotari · 4 days ago
  6. 4790c38 [fix][broker] Release entry on GetLastMessageId when parseMessageMetadata throws (#26089) by SongOf · 5 days ago
  7. 32146ae [fix][broker] Prevent stale service unit callbacks from dropping active lookup and cleanup jobs (#26146) by void-ptr974 · 6 days ago
  8. aa3ec21 [fix][broker] Fix TableViewLoadDataStoreImpl close deadlock that stalls broker shutdown (#26243) by Lari Hotari · 6 days ago
  9. 3ebf796 [fix][client] Fix unAckedMessageTracker cleanup on multi-topics batch ack (#26001) by Dream95 · 6 days ago
  10. f07e0ed [fix][fn] Forward source message properties in Python runtime (#26191) by sbourkeostk · 6 days ago
  11. c6fd26f [fix][broker] Fix silently dropped acknowledgement failures in PulsarMetadataEventSynchronizer (#26237) by SongOf · 6 days ago
  12. c5cb6fc [fix][broker] Fix delayed message index data loss when trimming overlapping bucket snapshots (#26240) by void-ptr974 · 6 days ago
  13. 931f9fb [fix][broker] Fix incorrect listener URLs returned by ModularLoadManager lookups (#26245) by void-ptr974 · 6 days ago
  14. bc0e8b5 [fix][broker] Prevent completing replicated snapshot before marker publish (#26119) by sinan liu · 6 days ago
  15. 73549d2 [fix][broker] Prevent stale topic unload cleanup from removing active cache entries (#26145) by void-ptr974 · 6 days ago
  16. bc56ba8 [fix][meta] Complete handleMetadataEvent future exceptionally when the initial get fails (#26199) by SongOf · 6 days ago
  17. 78cc3f4 [fix][meta] Record get op stats on the correct completion branch in AbstractMetadataStore (#26201) by SongOf · 6 days ago
  18. 37ceb98 [fix][broker] Fix Key_Shared delivery stall when look-ahead triggers at the end of the topic (#26236) by Lari Hotari · 6 days ago
  19. a4b7aaa [fix][meta] Fix RocksdbMetadataStore instanceId not advancing across restarts (#26218) by SongOf · 6 days ago
  20. a965f5f [improve][offload] Support credentials from offload policies for S3 and Aliyun OSS drivers (#26232) by kannar · 6 days ago
  21. 1aa37ff [fix][ml] Preserve ledger entries/size when transformLedgerInfo callback completes after a concurrent close (#26228) by 道君- Tao Jiuming · 7 days ago
  22. 8aab815 [fix][sec] Upgrade grpc in pulsar-function-go to 1.82.1 to fix GHSA-hrxh-6v49-42gf (#26235) by Lari Hotari · 7 days ago
  23. 0679b0d [fix][broker] Prevent stale read completions from stranding Failover subscriptions (#26174) by Alexandre Burgoni · 8 days ago
  24. 99f5848 [fix][sec] Bump google.golang.org/grpc from 1.79.3 to 1.82.1 in /pulsar-function-go/examples (#26231) by dependabot[bot] · 8 days ago
  25. 4bfb080 [improve][misc] Upgrade Jetty to 12.1.11 (#26233) by Lari Hotari · 8 days ago
  26. 520b0da [fix][broker] Trigger max read position callback for messages published during transaction buffer recovery (#26234) by Lari Hotari · 8 days ago
  27. 094f270 [fix][broker] Check deliverAt before containsMessage in bucket addMessage (#26230) by Zixuan Liu · 8 days ago
  28. 79a2c6f [fix][ml] Preserve ledger properties when closing ledger (#26227) by 道君- Tao Jiuming · 8 days ago
  29. f51864c [improve][build] Upgrade slog to 0.10.0 (#26226) by Lari Hotari · 8 days ago
  30. 045d628 [improve][build] Upgrade docker base image Alpine to 3.24 (#26225) by Lari Hotari · 9 days ago
  31. 90cba32 [fix][fn] Return inputSpecs consumerProperties in function GET info (#26217) by Dream95 · 10 days ago
  32. 6302699 [fix][broker] Fix `getEstimatedSizeSinceMarkDeletePosition` throw `IllegalArgumentException` (#26184) by Jiwei Guo · 10 days ago
  33. 2ff3030 [fix][client] Preserve null values in pulsar-admin schema output (#26196) by Jiwei Guo · 10 days ago
  34. f1650c5 [fix][broker] Log exception in PulsarMetadataEventSynchronizer failure path (#26203) by SongOf · 11 days ago
  35. 0ca94f5 [fix][meta] Fix NPE in shouldIgnoreEvent when MetadataEvent options is null (#26200) by SongOf · 11 days ago
  36. 060b130 [improve][broker] Optimize SegmentedLongArray with heap-backed long[][] (#26183) by Zixuan Liu · 11 days ago
  37. c886c07 [improve][broker] Optimize bucket delayed-delivery bitmap point operations (#26205) by Zixuan Liu · 11 days ago
  38. 3d00280 [fix][cli] Fix V5 scalable-topics property parsing (#26177) by void-ptr974 · 13 days ago
  39. 842cfac [fix][test] Fix flaky test `testCompactionPriority ` (#26198) by Jiwei Guo · 13 days ago
  40. 8af7868 [fix][broker] Prevent partition expansion from inheriting delayed-delivery bucket state (#26179) by void-ptr974 · 2 weeks ago
  41. fe61afd [improve][broker] Skip system cursor when check inactive cursor. (#26149) by Yan Zhao · 2 weeks ago
  42. 8576283 [fix][client] Fix lookup permit double-release, waiting queue starvation and timeout-response races in ClientCnx (#26143) by zhou zhuohan · 2 weeks ago
  43. 1b32aa8 [improve][broker] Implemets PIP-487: add event count metrics for InflightReadsLimiter acquire and release operations (#26093) by fengyubiao · 2 weeks ago
  44. 545c325 [feat][pip]PIP-487 Add event count metrics for InflightReadsLimiter acquire and release operations (#26092) by fengyubiao · 2 weeks ago
  45. 0ae4d94 [improve][meta] Upgrade Oxia client to 0.9.4 (#26193) by Matteo Merli · 2 weeks ago
  46. 29028de [improve][broker] Trace the asynchronous tasks in logs when loading topics (#26163) by Yunze Xu · 2 weeks ago
  47. 16476b5 [fix][broker] Prevent early replay of non-strict delayed messages (#26188) by Cong Zhao · 2 weeks ago
  48. 39784e0 [improve][broker] PIP-486 (PR4): bucket-shared consumption for scale-up fan-out (#26173) by Matteo Merli · 3 weeks ago
  49. 403ee7f [fix][client] Scalable topics: stream consumer must not acknowledge on close or topic-removal (#26172) by Matteo Merli · 3 weeks ago
  50. 3529aba [fix][broker] Remove lock contention in delayed delivery stats read paths (#25990) by Zixuan Liu · 3 weeks ago
  51. c240dd2 [fix][broker] Fix bucket delayed message index metrics reset on scrape (#26171) by Zixuan Liu · 3 weeks ago
  52. a74268d [fix][broker] Fix BucketDelayedDeliveryTracker recovery after LightProto migration (#26160) by Zixuan Liu · 3 weeks ago
  53. 803ff96 [fix][broker] Read subscription properties directly from cursor (#26159) by Zixuan Liu · 3 weeks ago
  54. 73d61e4 [improve][client] Use SHA-256 for generated reader subscription names (#26153) by David Kjerrumgaard · 3 weeks ago
  55. a0f0f05 [improve][misc] Replace MD5 NAR/archive checksums with SHA-256 (#26152) by David Kjerrumgaard · 3 weeks ago
  56. 4c43acd [fix][sec] Upgrade Netty to 4.2.16.Final to address CVEs (#26167) by Lari Hotari · 3 weeks ago
  57. e86f59f [fix][sec] Downgrade Jackson version to 2.21.5 LTS (#26166) by Lari Hotari · 3 weeks ago
  58. 59d0ac9 [fix][ci] Upgrade sandboxed-trivy-action to approved sha (#26169) by Lari Hotari · 3 weeks ago
  59. f1dc639 [improve][client] Avoid per-message cross-topic vector deep copy in v5 multi-topic stream consumer (#26162) by Matteo Merli · 3 weeks ago
  60. 8d5cac6 [fix][metadata] Fix orphaned UR parent nodes not cleaned up with Oxia metadata backend (#26158) by Eugene Polozhenkov · 3 weeks ago
  61. 92bd098 [improve][client] Apply receiver-queue backpressure in v5 scalable consumers (#26151) by Matteo Merli · 3 weeks ago
  62. 4824983 [fix][ci] Update setup-gradle action to v6.2.0 to match ASF actions allowlist (#26156) by David Kjerrumgaard · 3 weeks ago
  63. a720463 [improve][broker] Reduce PendingAcksMap memory by replacing IntIntPair values with packed longs (#26030) by void-ptr974 · 4 weeks ago
  64. 100d3ef [improve][ml] Replace RangeSetWrapper with PositionRangeSet backed by LongBitmap (#26127) by Zixuan Liu · 4 weeks ago
  65. e85b1f7 [fix][client] Fix UnAckedMessageRedeliveryTracker to skip cancelled timeouts (#26043) by Dream95 · 4 weeks ago
  66. e8df873 [fix][client] Sync ackSet in client with broker to stop acked messages reaching the DLQ (#26135) by Yike Xiao · 4 weeks ago
  67. b805304 [improve][client] Make v5 scalable consumer receiveAsync truly non-blocking (#26131) by Matteo Merli · 4 weeks ago
  68. e0c58b0 [fix][test] Await reader reconnect after seek() to fix flaky TopicReaderTest assertions (#26141) by Lari Hotari · 4 weeks ago
  69. 055882b [fix][sec] Bump github.com/go-jose/go-jose/v4 from 4.1.3 to 4.1.4 in /pulsar-function-go (#26142) by dependabot[bot] · 4 weeks ago
  70. 82a5cdf [fix][sec] Upgrade pulsar-client-go to v0.20.0 in pulsar-function-go, also address CVEs (#26140) by Lari Hotari · 4 weeks ago
  71. 1b3e9ec [improve][fn] Upgrade pulsar-client-python to 3.13.0 (#26139) by Lari Hotari · 4 weeks ago
  72. 7a40ada [fix][fn] Reorder Function Worker shutdown to stop scheduler before runtime manager (#26136) by Dream95 · 4 weeks ago
  73. 0629dc5 [improve][broker] Load topic policies on non-persistent topic load and gate the policy replay (#26134) by Lari Hotari · 4 weeks ago
  74. decc80f [fix][broker] Don't let a closing topic-policies reader abort a concurrent cache-init reload (#26132) by Lari Hotari · 4 weeks ago
  75. 51236fc [fix][client] Cancel stale per-topic retry timers in v5 multi-topic consumers (#26130) by Matteo Merli · 4 weeks ago
  76. 8dd3c31 [improve][broker] PIP-486 (PR3): entry-bucket foundation (single-active by default) (#26129) by Matteo Merli · 4 weeks ago
  77. 12d8aa9 [fix][test] Run makeReadEntryProbFail's errorOrNot on a caller-provided executor (#26123) by Lari Hotari · 4 weeks ago
  78. b61f3d5 [improve][broker] Add LongBitmap abstraction and migrate RoaringBitmap usage to LongBitmap (#26117) by Zixuan Liu · 4 weeks ago
  79. aa2d1bc [fix][test] Fix flaky PersistentTopicsTest setup caused by concurrent Mockito stubbing (#26083) by void-ptr974 · 4 weeks ago
  80. 373ab2b [improve][fn] Standardize log4j2 Root logger configuration to use system property (#26121) by Malla Sandeep · 4 weeks ago
  81. 116212f [fix][test] Fix flaky AuditorBookieTest.testBookieClusterRestart (#26122) by Lari Hotari · 4 weeks ago
  82. baf2211 [fix][broker] Fix replication stall when a cursor rewind skips an in-flight read (#26106) by Lari Hotari · 4 weeks ago
  83. 1f45e88 [improve][broker] PIP-486 (PR2): controller entry-bucket budget per segment (#26118) by Matteo Merli · 4 weeks ago
  84. 320fbce [improve][client] PIP-486 (PR1): producer entry-bucketing for scalable topics (#26115) by Matteo Merli · 4 weeks ago
  85. 1fc861a [fix][test] Fix flaky PendingAckInMemoryDeleteTest.txnAckTestBatchAndSharedSubMemoryDeleteTest (#26116) by Lari Hotari · 4 weeks ago
  86. df9de1e [improve][broker] PIP-486: entry-bucket wire format, hash & layout foundation (#26114) by Matteo Merli · 5 weeks ago
  87. 6d12cce [improve][client] Log the exception in ControlledClusterFailover.close (#25925) by Pavel Zeger · 5 weeks ago
  88. 808133d [improve][pip] PIP-486: Scalable Topic Key-Shared Consumption (#26077) by Matteo Merli · 5 weeks ago
  89. b14524e [fix][broker] Forward topic policy updates after init failures (#26110) by sinan liu · 5 weeks ago
  90. abca10f [fix][broker] Fix replicator getting stuck under rate limiter throttling and honor readBatchSize/maxReadSizeBytes on the default read path (#26005) by void-ptr974 · 5 weeks ago
  91. 3754f07 [fix][sec] Upgrade Jackson to 2.22.0 (#26101) by Matteo Merli · 5 weeks ago
  92. febf873 [fix][test] Fix flaky GeoReplicationTest.testTopicReplication (#26090) by void-ptr974 · 5 weeks ago
  93. 0d2beba [improve][build] Trim unused JDK modules from the Docker image runtime (#26086) by Matteo Merli · 5 weeks ago
  94. 19db575 [improve][broker] Reduce persistent topic backlog check overhead with ManagedCursor.hasBacklog (#26058) by void-ptr974 · 5 weeks ago
  95. 29e95d3 [improve] Exclude filesystem offloader NAR from base image (#26085) by Matteo Merli · 5 weeks ago
  96. b2f3756 [improve][broker] Improve dispatch performance by summing entry bytes with a loop (#26055) by void-ptr974 · 5 weeks ago
  97. 51e2b9a [fix][broker] Guard BucketDelayedDeliveryTracker.nextDeliveryTime against empty queues (#26080) by 道君- Tao Jiuming · 5 weeks ago
  98. 4fd22bb [fix][broker]Do not trigger topic GC if replication is still active (#25915) by fengyubiao · 5 weeks ago
  99. 6d0d99b [feat][broker] Expose managed ledger properties via topic internal stats (#26079) by Yunze Xu · 5 weeks ago
  100. e45b425 [improve][broker] Trim orphaned bucket snapshots when ledgers are deleted (#25984) by 道君- Tao Jiuming · 5 weeks ago