Google Git
Sign in
apache/pulsar/HEAD
  1. 436ca72 [improve][fn] Upgrade Pulsar Python client version to 3.10.0 (#25251) by Lari Hotari · 5 days ago master
  2. 163b900 [fix][sec] Upgrade Python protobuf version to 6.33.5 to address CVE-2026-0994 (#25250) by Lari Hotari · 5 days ago
  3. 24eba10 [fix][meta] Metadata cache refresh might not take effect (#25246) by Yunze Xu · 6 days ago
  4. 48774de [fix][test] Fix ResourceQuotaCalculatorImplTest#testNeedToReportLocalUsage (#25247) by Yunze Xu · 6 days ago
  5. 9db31cc [fix][test] fix testBatchMetadataStoreMetrics. (#25241) by zzb · 10 days ago
  6. 4a88612 [feat][broker] PIP-452: Customizable topic listing of namespace with properties (#25160) by Cong Zhao · 10 days ago
  7. 1db61ac [improve][broker] Enhance advertised address resolution with fallback to localhost (#25238) by Zixuan Liu · 10 days ago
  8. 6b567e9 [improve][pip] PIP-447: Customizable Prometheus Labels for Topic Metrics (#25161) by Cong Zhao · 11 days ago
  9. d5145e4 [fix][sec] Override msgpack-core to 0.9.11 to address CVE-2026-21452 (#25233) by guptas6est · 11 days ago
  10. db91b93 [improve] Upgrade Netty to 4.1.131.Final (#25232) by Lari Hotari · 12 days ago
  11. 9740408 [feat][pip] PIP-452: Customizable topic listing of namespace with properties (#25134) by Cong Zhao · 13 days ago
  12. 0e5d424 [fix][broker] Fix transactionMetadataFuture completeExceptionally with null value (#25231) by Hao Zhang · 13 days ago
  13. f42cd25 [fix][client] Send all chunkMessageIds to broker for redelivery (#25229) by cai minjian · 13 days ago
  14. 0a0ce6d [improve][broker] Give the detail error msg when authenticate failed with AuthenticationException (#25221) by Jiwei Guo · 13 days ago
  15. c93dd7a [fix][test] Fix Mockito stubbing race in TopicListServiceTest (#25227) by sinan liu · 13 days ago
  16. c2ae180 [fix][broker] Fix incomplete futures in topic property update/delete methods (#25228) by Cong Zhao · 13 days ago
  17. 6c79d3a [improve][test] Set k8s test retry count to 0 (#25230) by Philipp Dolif · 13 days ago
  18. 63220ea [improve][broker] Add idle timeout support for http (#25224) by Zixuan Liu · 2 weeks ago
  19. 3cb7a7b [improve][client] Make authorization server metadata path configurable in AuthenticationOAuth2 (#25052) by Hideaki Oguni · 2 weeks ago
  20. bae9173 [improve][broker] Add strictAuthMethod to require explicit authentication method (#25185) by Omar Yasin · 2 weeks ago
  21. 2d6ef6f [fix][broker] Fix httpProxyTimeout config (#25223) by Zixuan Liu · 2 weeks ago
  22. 00a65e3 [improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200) by Yike Xiao · 2 weeks ago
  23. 6f4ac21 [feat][io] implement pip-297 for jdbc sinks (#25195) by Bäm · 2 weeks ago
  24. e160b1a [improve][admin] Add client side looping to analyze-backlog in Topics to avoid potential HTTP call timeout (#25127) by Oneby Wang · 2 weeks ago
  25. 6433309 [fix][sec] Upgrade OpenSearch to 2.19.4 to remediate CVE-2025-9624 (#25206) by guptas6est · 2 weeks ago
  26. 2e06cc0 [fix][broker] Prevent missed topic changes in topic watchers and schedule periodic refresh with patternAutoDiscoveryPeriod interval (#25188) by Lari Hotari · 2 weeks ago
  27. 6d957646 [fix][test] Use AtomicBoolean.compareAndSet() to guarantee atomicity in testDoIndividualBatchAckNeverAffectIsDuplicate() method (#25217) by Oneby Wang · 2 weeks ago
  28. 611efe4 [fix][client] Fix producer synchronous retry handling in failPendingMessages method (#25207) by Malla Sandeep · 2 weeks ago
  29. 827bc4f [improve][io] Set default connector class for debezium connectors (#25215) by jiangpengcheng · 2 weeks ago
  30. 6d51f88 [fix][broker]Fix ledgerHandle failed to read by using new BK API (#25199) by fengyubiao · 2 weeks ago
  31. bea6f8a [fix][broker] Fix ManagedCursorImpl.asyncDelete() method may lose previous async mark delete properties in race condition (#25165) by Oneby Wang · 2 weeks ago
  32. 257d42f [fix][test]Fix flaky ExtensibleLoadManagerImplTest_testGetMetrics (#25216) by fengyubiao · 2 weeks ago
  33. e8fedb1 [improve][proxy] Add regression tests for package upload with 'Expect: 100-continue' (#25211) by Zixuan Liu · 2 weeks ago
  34. 3dc1fd6 [cleanup][doc]Remove TRACING.md as it has been moved to pulsar-site (#25213) by Penghui Li · 2 weeks ago
  35. 6d415c6 [improve][meta] PIP-453: Improve the metadata store threading model (#25187) by Yunze Xu · 3 weeks ago
  36. 5aab2f0 [fix][client] Fix race condition between isDuplicate() and flushAsync() method in PersistentAcknowledgmentsGroupingTracker due to incorrect use Netty Recycler (#25208) by Oneby Wang · 3 weeks ago
  37. 4add84c [fix] [test] Upgrade docker-java to 3.7.0 (#25209) by Matteo Merli · 3 weeks ago
  38. cab92f0 [revert] "[improve][build] Build docker image only once when pushing" (#25203) by Zixuan Liu · 3 weeks ago
  39. c07f2ad [fix][sec] Exclude org.lz4:lz4-java and standardize on at.yawk.lz4-java to remediate CVE-2025-12183 and CVE-2025-66566 (#25198) by guptas6est · 3 weeks ago
  40. d630394 [fix][misc] Allow JWT tokens in OpenID auth without nbf claim (#25197) by Lari Hotari · 3 weeks ago
  41. d0efdd7 [improve][build] Build docker image only once when pushing (#25194) by Zixuan Liu · 3 weeks ago
  42. 52a4d5e [improve][client]Reduce unnecessary getPartitionedTopicMetadata requests when using retry and DLQ topics. (#25172) by zhenJiangWang · 4 weeks ago
  43. ce4ebea [fix][test] Bump org.assertj:assertj-core from 3.27.5 to 3.27.7 (#25186) by dependabot[bot] · 4 weeks ago
  44. c51346f [improve][pip] PIP-453: Improve the metadata store threading model (#25173) by Yunze Xu · 4 weeks ago
  45. b15f53b [improve][misc] Upgrade snappy version to 1.1.10.8 (#25182) by Lari Hotari · 4 weeks ago
  46. 2d04c93 [improve][misc] Upgrade to Alpine 3.23 (#25180) by Lari Hotari · 4 weeks ago
  47. 3348470 [fix][proxy] Close client connection immediately when credentials expire and forwardAuthorizationCredentials is disabled (#25179) by Zixuan Liu · 4 weeks ago
  48. f0ec07b [fix][client] ControlledClusterFailover avoid unnecessary reconnection. (#25178) by Wenzhi Feng · 4 weeks ago
  49. a2f888a [fix][sec] Bump org.apache.solr:solr-core from 9.8.0 to 9.10.1 in /pulsar-io/solr (#25175) by dependabot[bot] · 4 weeks ago
  50. 9b70ba3 [fix][ml] Fix NoSuchElementException in EntryCountEstimator caused by a race condition (#25177) by Lari Hotari · 4 weeks ago
  51. 45def39 [improve][broker] Upgrade bookkeeper to 4.17.3 (#25166) by Yong Zhang · 5 weeks ago
  52. 7b87a6a [fix][build] Fix Eclipse/VSCode support after Jetty 12 upgrade (#25169) by Lari Hotari · 5 weeks ago
  53. 85625e0 [improve][doc] Suggest to raise documentation issues to the site repo (#25162) by Kiryl Valkovich · 5 weeks ago
  54. 2a29be0 [improve][broker] Ensure metadata session state visibility and improve Unstable observability for ServiceUnitStateChannelImpl (#25132) by Kai Wang · 5 weeks ago
  55. fca90d1 [improve][broker] PIP-433: Ensure topic creation before starting GEO (#24652) by Zixuan Liu · 5 weeks ago
  56. fcbafaa Add Dekaf UI to README.md (#25159) by Kiryl Valkovich · 5 weeks ago
  57. 805c71d [improve][broker] PIP-442: Add memory limits for topic list watcher (part 2) (#25070) by Lari Hotari · 5 weeks ago
  58. 0bf560f [fix][fn] Fix graceful Pulsar Function shutdown so that consumers and producers are closed (#25157) by Lari Hotari · 5 weeks ago
  59. f5fc992 [fix][build] Fix IntelliJ build after Jetty 12 upgrade (#25155) by Lari Hotari · 5 weeks ago
  60. 413387b [fix][test] Fix the flaky test ProduceWithMessageIdTest. sendWithCallBack (#25150) by Jiwei Guo · 5 weeks ago
  61. 6a3066d [fix][broker] Fence reset cursor by timestamp to avoid concurrent timestamp-based position lookups (#25151) by Penghui Li · 5 weeks ago
  62. dff4f1e [fix][sec] Upgrade vertx to address CVE-2026-1002 (#25152) by Lari Hotari · 5 weeks ago
  63. 16bcec3 [fix][ml] Retry offload reads when OffloadReadHandleClosedException is encountered (#25148) by Penghui Li · 5 weeks ago
  64. 0d5358a [fix][admin] Fix offload policy incompatible issue. (#25149) by Jiwei Guo · 5 weeks ago
  65. 99fdca8 [fix][proxy] Fix memory leaks in ParserProxyHandler (#25142) by Lari Hotari · 5 weeks ago
  66. 39dbbf0 [improve][misc] Upgrade to Jetty 12.1.x (#25100) by Lari Hotari · 6 weeks ago
  67. eb59e49 [fix][test] Fix flaky ModularLoadManagerImplTest.testRemoveNonExistBundleData (#25143) by Lari Hotari · 6 weeks ago
  68. 4346165 [improve][ci] update pulsarbot to use github-script based implementation (#24940) by Xiangying Meng · 6 weeks ago
  69. a373258 [feat][client] PIP-446: Support Native OpenTelemetry Tracing in Pulsar Java Client (#24873) by Jiwei Guo · 6 weeks ago
  70. 21819c6 [fix][fn] complete flushAsync before closeAsync in ProducerCache and wait for completion in closing the cache (#25140) by Ilya Brin · 6 weeks ago
  71. 03082bc [improve][io] Add PUT method support to HttpSink (#25133) by Dream95 · 6 weeks ago
  72. 38807b1 [fix][broker] Avoid split non-existent bundle (#25031) by Cong Zhao · 6 weeks ago
  73. 1708933 [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Managed Transaction Wrapping (#24704) by wzhramc · 6 weeks ago
  74. 1fcdf8b [fix][broker] Fix regex matching of namespace name which might contain a regex char (#25136) by Lari Hotari · 6 weeks ago
  75. 1617bb2 [fix][broker] Fix markDeletedPosition race condition in ManagedLedgerImpl.maybeUpdateCursorBeforeTrimmingConsumedLedger() method (#25110) by Oneby Wang · 6 weeks ago
  76. d72dc04 [improve][broker] Change the log level from error to info when throwing NotAllowedException (#25130) by Jiwei Guo · 6 weeks ago
  77. 40953cb [fix][test] Wait for txn.abort() to complete to avoid AdminApiTransactionTest.testAnalyzeSubscriptionBacklogWithTransactionMarker() flaky test (#25125) by Oneby Wang · 7 weeks ago
  78. b4b05b5 [fix][broker]Topic deleting failed after removed local cluster from namespace policies (#25114) by fengyubiao · 7 weeks ago
  79. bf98773 [fix][admin] Fix asyncGetRequest to handle 204 (#25124) by Zixuan Liu · 7 weeks ago
  80. b1019ce [improve][broker] Enhance logging for adding schema failures in ServerCnx (#25048) by Cong Zhao · 7 weeks ago
  81. f101811 [fix][broker] Fix compaction horizon might be reset to an old position when phase two is interrupted (#25119) by Yunze Xu · 7 weeks ago
  82. 3e6133e [fix][broker] fix flaky test in SystemTopicBasedTopicPoliciesServiceTest (#25098) by ken · 7 weeks ago
  83. 68d3779 [improve][broker] Fix thread safety issue in ManagedCursorImpl.removeProperty (#25104) by Ruimin MA · 7 weeks ago
  84. af6c2dd [feat][pip] PIP-446: Support Native OpenTelemetry Tracing in Pulsar Java Client (#24857) by Jiwei Guo · 7 weeks ago
  85. 8864e2d [feat][pip] PIP-447: Customizable Prometheus Labels for Topic Metrics (#24862) by Cong Zhao · 7 weeks ago
  86. 133fe20 [fix][broker] Fix MultiRolesTokenAuthorizationProvider error when subscription prefix doesn't match. (#25121) by Shen Liu · 7 weeks ago
  87. 793e947 [fix][ml] Fix cursor backlog size to account for individual acks (#25089) by Penghui Li · 7 weeks ago
  88. 75658cc [improve][admin] Add counter for marker messages in PersistentTopics.analyzeSubscriptionBacklog() rest api (#25091) by Oneby Wang · 7 weeks ago
  89. df89b60 [fix][broker] Fix chunked message loss when no consumers are available (#25077) by zhenJiangWang · 7 weeks ago
  90. ff0d0eb [fix][test] Fix flaky PulsarFunctionsK8STest (#25108) by Philipp Dolif · 8 weeks ago
  91. ab65faa [fix][client]Producer stuck or geo-replication stuck due to wrong value of message.numMessagesInBatch (#25106) by fengyubiao · 9 weeks ago
  92. 9c5e1c3 [fix][test] Fix ManagedCursorTest and NonDurableCursorTest flaky tests (#25101) by Oneby Wang · 9 weeks ago
  93. fbab357 [fix][broker]pulsar_ml_reads_inflight_bytes and pulsar_ml_reads_available_inflight_bytes are 0 at the same time (#25105) by Penghui Li · 9 weeks ago
  94. 4495525 [fix][sec] Upgrade log4j to 2.25.3 to address CVE-2025-68161 (#25102) by Lari Hotari · 9 weeks ago
  95. 3fb52c5 [fix][sec] Upgrade jose4j to 0.9.6 to address CVE-2024-29371 (#25095) by Lari Hotari · 9 weeks ago
  96. 621b41f [fix][ci] Move flaky asyncMarkDeleteBlocking tests to flaky group (#25096) by Lari Hotari · 9 weeks ago
  97. e041fab [fix][admin] Refactor namespace anti affinity group sync operations to async in rest api (#25086) by Oneby Wang · 10 weeks ago
  98. 26297ac [fix][broker] Fix cursor position persistence in ledger trimming (#25087) by Penghui Li · 10 weeks ago
  99. d80401f [improve][io] Replace Qpid in tests with RabbitMQ in Testcontainers and upgrade RabbitMQ client version (#25085) by Lari Hotari · 10 weeks ago
  100. 611a3a4 [fix][build] Activate jdk21 and jdk24 profiles on Java 25 (#25084) by Lari Hotari · 10 weeks ago