Google Git
Sign in
apache/pulsar/HEAD
  1. c28dd85 [feat]PIP-468: Wire transactions into V5 client (#25631) by Matteo Merli · 4 hours ago master
  2. 6991461 [fix][broker] PIP-460: Authorize scalable topic binary commands (#25635) by Lari Hotari · 5 hours ago
  3. f662459 [feat] PIP-468: Multi-broker shared cluster + V5 cross-broker tests (#25633) by Matteo Merli · 5 hours ago
  4. b4df3c6 [improve][ci] Document avoiding reflection in tests in Copilot review instructions (#25636) by Lari Hotari · 6 hours ago
  5. 4f73b43 [feat][broker] PIP-468: Filter scalable topics by property via secondary index (#25632) by Matteo Merli · 6 hours ago
  6. cd910c2 [feat] PIP-468: Auto-reconnect scalable consumer session on disconnect (#25623) by Matteo Merli · 12 hours ago
  7. 145b3a5 [fix][client] PIP-468: V5 CheckpointConsumer consumer-group support (#25622) by Matteo Merli · 12 hours ago
  8. 759a5f5 [fix][broker] Fix stuck chunks in SharedConsumerAssignor permit tracking (#25620) by Matteo Merli · 13 hours ago
  9. 1a6b69d [feat] PIP-468: V5 StreamConsumer disconnect / reconnect / past-grace reassignment (#25619) by Matteo Merli · 13 hours ago
  10. d861e15 [fix][broker] Close pending acks cleanup gap in BacklogQuotaManager (#25624) by Zixuan Liu · 19 hours ago
  11. 71462d3 [improve][broker]Part-3 of PIP-433: always allow replicator to register a new compatible schema (#25461) by fengyubiao · 23 hours ago
  12. d200fd5 [improve][broker] Add authn/authz to Scalable Topics Admin API (PIP-460) (#25618) by Lari Hotari · 30 hours ago
  13. 88fcfa6 [feat][broker] PIP-466: Add supports_scalable_topics feature flag and broker config (#25616) by Lari Hotari · 34 hours ago
  14. 138595f [fix][broker] Move pending acks cleanup to selected mark-delete callbacks (#25592) by Zixuan Liu · 35 hours ago
  15. 35ec14a [fix][client] PIP-468: Wire V5 StreamConsumer to broker SubscriptionCoordinator (#25612) by Matteo Merli · 2 days ago
  16. 8a7eed3 [test][client-v5] V5 layout-dynamics coverage + consumer fixes (DAG replay, late-ack) (#25611) by Matteo Merli · 2 days ago
  17. 1260980 [fix] Client-v5: Retry producer send on AlreadyClosed across segment seal (#25610) by Matteo Merli · 2 days ago
  18. 00577a5 [fix][broker] Fix precision loss in DataSketchesSummaryLogger by replacing LongAdder with DoubleAdder for sum accumulation (#25594) by zhenJiangWang · 2 days ago
  19. d69c787 [fix][test] Fix flaky ExtensibleLoadManagerImplTest.testLoadBalancerServiceUnitTableViewSyncer (#25596) by Matteo Merli · 2 days ago
  20. f10be84 [fix][test] Fix flaky ManagedLedgerTest.testInvalidateReadHandleWhenConsumed (#25595) by Matteo Merli · 2 days ago
  21. c94e3f5 [feat] [test] PIP-468: V5 producer/consumer knob coverage + related client fixes (#25588) by Matteo Merli · 2 days ago
  22. d6ca792 [improve][client] Implement tls_client_auth for AuthenticationOAuth2 (#25538) by Hideaki Oguni · 2 days ago
  23. f92a4a0 [feat] PIP-468: Basic end-to-end tests for V5 Queue/Stream/Checkpoint consumers + async APIs (#25587) by Matteo Merli · 2 days ago
  24. b56c1de [fix][test] Fix flaky PulsarFunctionsJavaThreadTest.testTumblingCountWindowTest (#25590) by Praveen Kumar · 3 days ago
  25. 9e1bae3 [fix][broker] Fix race in pending acks removal in redeliverUnacknowledgedMessages (#25589) by Zixuan Liu · 3 days ago
  26. 03ed3af [improve][client] Add SOCKS5 proxy support for PulsarAdmin and for PulsarClient HTTP lookups (#25575) by xiaolong ran · 3 days ago
  27. 7b49b38 [feat] PIP-468: V5 client end-to-end smoke test + segment-bypass for internal subscribe/read (#25586) by Matteo Merli · 3 days ago
  28. 5168fcb [fix][broker] Decrement unacked counter when removeAllUpTo removes pending acks (#25581) by Zixuan Liu · 4 days ago
  29. ad114ad [feat][broker]:Support broker configuration for BookKeeper client TCP keep-alive options (#25580) by xiaolong ran · 4 days ago
  30. 13e1fac [improve][cli] Add client side looping in "pulsar-admin topics analyze-backlog" cli to avoid potential HTTP call timeout (#25126) by Oneby Wang · 4 days ago
  31. 33fe755 [feat][pip] PIP-469: Legacy-aware topic policies backend routing and metadata-store topic policies (#25547) by Yunze Xu · 4 days ago
  32. f07dece [fix][broker] Wait for orphan schema ledger cleanup before retry (#25579) by sinan liu · 4 days ago
  33. f459a1a [feat] PIP-468: Implement V5 client with scalable topic producer and consumer types (#25573) by Matteo Merli · 6 days ago
  34. f6598d8 [fix][client] Stabilize scaleReceiverQueueHint against concurrent enqueue/take (#25578) by Matteo Merli · 6 days ago
  35. 3c5c866 [feat] PIP-468: Add scalable topics and segments admin APIs with CLI (#25565) by Matteo Merli · 6 days ago
  36. 597eb0d [feat] PIP-468: Add scalable topic protocol commands and connection handling (#25564) by Matteo Merli · 6 days ago
  37. 527efb6 [feat] PIP-468: Add ScalableTopicController and broker infrastructure (#25559) by Matteo Merli · 6 days ago
  38. fae3df95 [improve][client] Best-effort retry for individual/batch-index acks on send failure when ackReceiptEnabled=false (#25525) by Zixuan Liu · 7 days ago
  39. 2476b1b [improve][fn] Log function package download completion and process PID (#25568) by Lari Hotari · 8 days ago
  40. 01fedb8 [fix][broker] Clean up orphan ledger on concurrent initial schema creation in BookkeeperSchemaStorage (#25514) by zhou zhuohan · 8 days ago
  41. 81a7753 [fix][broker] Replace Java serialization with JSON in package metadata (#25570) by Lari Hotari · 8 days ago
  42. a14f6cc [fix][sec] Upgrade BouncyCastle to 1.84 (CVE-2026-5588, CVE-2026-0636) (#25569) by Lari Hotari · 8 days ago
  43. db94b95 [improve][broker] Use full bundle name for namespace bundle destination affinity in ModularLoadManagerImpl (#25518) by Kai Wang · 8 days ago
  44. 4addfda [fix] Fix flaky BrokerDispatchRateLimiterTest.testBrokerDispatchThrottledMetrics (#25567) by Pavel Zeger · 8 days ago
  45. 1071cc9 [fix][test] Flaky SameAuthParamsLookupAutoClusterFailoverTest (#25566) by Lari Hotari · 9 days ago
  46. 77999fc [fix][test] Fix flaky OffloadPrefixTest.testPositionOnEdgeOfLedger race with ledger rollover (#25561) by Matteo Merli · 9 days ago
  47. 43c7ad8 [fix][test] Extend SameAuthParamsLookupAutoClusterFailoverTest phase timeouts (#25563) by Matteo Merli · 9 days ago
  48. 9cf1cc9 [fix][broker] pulsar admin stats internal with metadata command (#25557) by Rahul · 9 days ago
  49. f26e3ba [fix][test] Relax BrokerRegistryIntegrationTest broker-close threshold (#25562) by Matteo Merli · 9 days ago
  50. 293eafc [fix][test] Recreate EventLoop in PublishRateLimiterTest setup (#25560) by Matteo Merli · 9 days ago
  51. 423a746 [fix][broker] Lower log level of DrainingHashesTracker not-found entry to DEBUG (#25558) by Vishal Kumar Singh · 9 days ago
  52. 93d13e2 [fix][doc] Correct loadConf example key in PulsarAdminBuilder (#25556) by Vishal Kumar Singh · 9 days ago
  53. c6c9032 [feat] PIP-468: Scalable Topic Controller (#25516) by Matteo Merli · 9 days ago
  54. d553cec [improve][ml] Warn and emit metric when cursor ack state exceeds persist limits (#25548) by Alexandre Boyer · 10 days ago
  55. 3130a93 [improve][broker] Improve the performance of TopicName constructor (#24463) by Yunze Xu · 10 days ago
  56. 8c4e83d [improve][common] Optimize TopicName.get() to reduce lock contention on cache lookup (#25367) by Xiangying Meng · 10 days ago
  57. 6ce15e13 [feat] PIP-466: Add V5 client API for scalable topics (#25489) by Matteo Merli · 10 days ago
  58. 9e4e7e1 [feat] [pip] PIP-466: New Java Client API (V5) with Scalable Topic Support (#25455) by Matteo Merli · 10 days ago
  59. 9033223 [fix][broker]Namespaces can be created with may empty replication_clusters policy (#25551) by fengyubiao · 11 days ago
  60. a1613bc [fix][sec] Upgrade to async-http-client 2.14.5 to address CVE-2026-40490 (#25546) by Lari Hotari · 14 days ago
  61. a4c291f [fix][broker] Avoid Project access in broker test setup (#25529) by Zixuan Liu · 14 days ago
  62. 744d2b8 [improve][broker] Log only non-default config values on broker startup (#25545) by Matteo Merli · 14 days ago
  63. 91c165c [improve] PIP-467: Convert Jetty request logs to structured slog events (#25543) by Matteo Merli · 2 weeks ago
  64. af2eba9 [improve] PIP-467: Remove now-dead slf4j.api dependency from modules converted to slog (#25541) by Matteo Merli · 2 weeks ago
  65. 97329ba [improve][misc] Add deepwiki badge in README to enable automated index update (#25544) by Lari Hotari · 2 weeks ago
  66. ae2b8c7 [improve] Emit flat OpenTelemetry JSON logs instead of ECS (#25542) by Matteo Merli · 2 weeks ago
  67. d135252 [improve][test] PIP-467: Convert pulsar-broker test files logging from SLF4J to slog (#25536) by Matteo Merli · 2 weeks ago
  68. 4998cd9 [improve] PIP-467: Convert pulsar-broker module logging from SLF4J to slog (#25535) by Matteo Merli · 2 weeks ago
  69. e05c212 [fix][sec] Upgrade Jetty to address CVE-2026-5795 (#25532) by Lari Hotari · 2 weeks ago
  70. dfb06f1 [fix][sec] Upgrade log4j to 2.25.4 to address CVE-2026-34477, CVE-2026-34478, CVE-2026-34480, CVE-2026-34481 (#25521) by Matteo Merli · 2 weeks ago
  71. 40edde7 [improve] PIP-467: Convert remaining modules logging from SLF4J to slog (#25511) by Matteo Merli · 2 weeks ago
  72. 4c96c73 [fix][sec] Upgrade Jetty to address CVE-2026-2332 (#25527) by Lari Hotari · 2 weeks ago
  73. 352147b [fix][broker] Revert "[improve][broker] Enhance advertised address resolution with fallback to localhost (#25238)" (#25523) by Zixuan Liu · 2 weeks ago
  74. a8e6296 [fix] Fix typo 'seperated' in broker comments (#25524) by Mukunda Rao Katta · 2 weeks ago
  75. 85937d8 [fix][broker] Unthrottle producers immediately when publish rate limiting is disabled (#25502) by Wenzhi Feng · 2 weeks ago
  76. 840fc34 [improve] PIP-467: Convert pulsar-functions module logging from SLF4J to slog (#25508) by Matteo Merli · 2 weeks ago
  77. 8545ca4 [improve] Add PULSAR_LOG_FORMAT env var for easy JSON logging (#25515) by Matteo Merli · 2 weeks ago
  78. f688ff7 [improve][broker] Close connection when close consumer write fails (#25520) by Zixuan Liu · 2 weeks ago
  79. daa5f8d [improve] PIP-467: Convert pulsar-client module logging from SLF4J to slog (#25507) by Matteo Merli · 3 weeks ago
  80. cf7f9d9 [improve][all] Upgraded Jackson to 2.21 LTS and fixed a few gradle assemble warnings (#25504) by Abhilash Mandaliya · 3 weeks ago
  81. 089f87f [fix][ci] Ensure discard_max_bytes is set to 0 only for existing block devices (#25510) by Zixuan Liu · 3 weeks ago
  82. bf45974 [fix][test] Fix flaky ExtensibleLoadManagerImpl client reconnection tests: PulsarClientException$AlreadyClosedException: Client already closed (#25509) by void-ptr974 · 3 weeks ago
  83. aec41c4 [improve][broker] update broker error message to include tenant name (#25503) by Paul Gier · 3 weeks ago
  84. 792a76a [improve] PIP-467: Convert pulsar-common module logging from SLF4J to slog (#25506) by Matteo Merli · 3 weeks ago
  85. 9855b18 [improve] PIP-467: Convert pulsar-metadata module logging from SLF4J to slog (#25505) by Matteo Merli · 3 weeks ago
  86. a39d241 [improve] PIP-467: Convert managed-ledger module logging from SLF4J to slog (#25490) by Matteo Merli · 3 weeks ago
  87. dfe03c4 [improve][client] PIP-234: Support sharing the memory limit controller across multiple isolated Pulsar client instances (#25477) by Oneby Wang · 3 weeks ago
  88. c86a040 [cleanup][build] Remove unused structured-event-log module (#25492) by Matteo Merli · 3 weeks ago
  89. 12bcd6b [fix][test] Fix flaky ExtensibleLoadManagerTest.startBroker timeout (#25500) by Lari Hotari · 3 weeks ago
  90. 5b2778e [fix] Upgrade Jetty to 12.1.6 to fix CVE-2026-1605 (#25485) by Matteo Merli · 3 weeks ago
  91. 0c86cf0 [improve] Add context map to log4j2 pattern layouts (#25491) by Matteo Merli · 3 weeks ago
  92. 37696d2 [fix][test] Fix flaky TopicFromMessageTest by using unique topic names (#25494) by Matteo Merli · 3 weeks ago
  93. 0309a99 [fix][test] Fix flaky InterceptorsTest and ProduceWithMessageIdTest (#25499) by Matteo Merli · 3 weeks ago
  94. 7ce8a8c [fix][test] Fix flaky ServerCnxTest.testCreateProducerTimeoutThenCreateSameNamedProducerShouldFail (#25497) by Lari Hotari · 3 weeks ago
  95. 104ea57 [fix][test] Fix flaky ManagedLedgerTest.testNoRetention and testInvalidateReadHandleWhenDeleteLedger (#25495) by Lari Hotari · 3 weeks ago
  96. 41a3932 [improve][build] Add Maven publishing conventions for ASF release (#25457) by Lari Hotari · 3 weeks ago
  97. d96da97 [fix][test] Fix flaky ModularLoadManagerImplTest and IsolatedBookieEnsemblePlacementPolicyTest (#25496) by Lari Hotari · 3 weeks ago
  98. 0417705 [fix][test] Fix flaky LeaderElectionServiceTest and PersistentDispatcherFailoverConsumerTest (#25498) by Lari Hotari · 3 weeks ago
  99. 381fa13 [fix][test] Fix thread resource leaks in tests and PrometheusMetricsProvider (#25487) by Lari Hotari · 3 weeks ago
  100. 0f97cba [fix][test] Fix flaky ReplicatorTest.testResumptionAfterBacklogRelaxed (#25493) by Lari Hotari · 3 weeks ago