Google Git
Sign in
apache/pulsar/HEAD
  1. f9cf140 [improve][ml] Migrate managed-ledger from protobuf to LightProto (#25336) by Matteo Merli · 4 hours ago master
  2. af92a5f [fix][broker] Fix concurrency bug in BucketDelayedDeliveryTracker (#25346) by Matteo Merli · 4 hours ago
  3. ff9f1b9 [fix][test] Fix flaky PersistentTopicTerminateTest.testRecoverAfterTerminate (#25345) by Matteo Merli · 5 hours ago
  4. 7f6bc23 [cleanup] Convert 13 test classes to SharedPulsarBaseTest (#25331) by Matteo Merli · 23 hours ago
  5. 2bd9dd0 [improve][build] Upgrade LightProto to 0.6.1 (#25332) by Matteo Merli · 26 hours ago
  6. be87cd9 [fix][broker]system topic was created with different partitions acrossing clusters after enabled namespace-level replication (#25312) by fengyubiao · 32 hours ago
  7. ae5c70c [improve] Add secondary index support to MetadataStore (#25328) by Matteo Merli · 2 days ago
  8. 3222c56 [cleanup] Convert 10 test classes to SharedPulsarBaseTest (#25327) by Matteo Merli · 2 days ago
  9. 5ddc949 [cleanup] Convert 15 test classes to SharedPulsarBaseTest (#25318) by Matteo Merli · 2 days ago
  10. 3936ce4 [fix][broker] Handle missing replicator during snapshot request processing (#25266) by sinan liu · 2 days ago
  11. a30deb4 [fix][io][kca] kafka headers silently dropped (#25325) by Enrique Fernández · 2 days ago
  12. 1b5c818 [fix][client] Fail messages immediately in ProducerImpl when in terminal state (#25317) by Matteo Merli · 2 days ago
  13. 2e3e78d [cleanup] PIP-457: Remove NamespaceName.isGlobal() and TopicName.isGlobal() (#25319) by Matteo Merli · 2 days ago
  14. 5067d0d [fix][test] Fix flaky ConnectionTimeoutTest by correcting latch count (#25320) by Matteo Merli · 2 days ago
  15. 735b429 [fix] PIP-457: Remove support for V1 topic names and V1 Admin API (implementation) (#25304) by Matteo Merli · 5 days ago
  16. ce5bc13 [improve][test] Introduce shared Pulsar cluster for faster integration tests (#25311) by Matteo Merli · 6 days ago
  17. 0495c8a [fix] Fix flaky OneWayReplicatorTest.testTopicPoliciesReplicationRule (#25316) by Matteo Merli · 6 days ago
  18. d0fa363 [fix][test] Fix flaky OneWayReplicatorUsingGlobalZKTest cleanup (#25313) by Matteo Merli · 6 days ago
  19. b171b05 [fix][test] Fix flaky PulsarDebeziumOracleSourceTest (#25314) by Matteo Merli · 7 days ago
  20. 6c357f6 [fix] Fix flaky testEstimatedTimeBasedBacklogQuotaCheckWhenNoBacklog (#25307) by Matteo Merli · 7 days ago
  21. f1aac3d [improve][broker]Part-2 of PIP-433 add validation when enabling namespace-level Geo-Replication (#25170) by fengyubiao · 8 days ago
  22. 8798a46 [improve][CI] Add Copilot instructions based on Pulsar Java coding conventions (#25305) by Hao Zhang · 8 days ago
  23. c83cafc [fix][offload] Close all resources in BlobStoreBackedReadHandleImplV2.closeAsync (#25296) by Sanjay Malakar · 9 days ago
  24. 5081c02 [fix][sec] Bump org.apache.zookeeper:zookeeper from 3.9.4 to 3.9.5 (#25303) by dependabot[bot] · 9 days ago
  25. ec4bb77 [cleanup] PIP-457: Remove support for V1 topic names and V1 Admin API (#25275) by Matteo Merli · 9 days ago
  26. 35dae97 [fix][broker] Return failed future instead of throwing exception in async methods (#25289) by Hao Zhang · 9 days ago
  27. c70f263 [fix][build] Fix compilation issues for PR #25219 changes after merging conflicting PR #25278 (#25300) by Lari Hotari · 9 days ago
  28. 8332499 [improve][ml] Clean up managed-ledger code: deduplicate logic and use shared utilities (#25298) by Penghui Li · 9 days ago
  29. de5221b [fix][client] Fix async APIs to return failed futures on validation errors (#25287) by Hao Zhang · 9 days ago
  30. 0bc9dcb [improve][broker] Update netty allocator default chunk size from 4MB to 8MB, and move internal JVM opts from PULSAR_EXTRA_OPTS to OPTS (#25274) by zhou zhuohan · 9 days ago
  31. e0fb301 [cleanup] Refactored Backoff to be more consistent and intuitive to use (#25278) by Matteo Merli · 9 days ago
  32. e902c68 [feat][monitor] PIP-447 for Customizable Prometheus Labels for Topic Metrics (#24991) by Cong Zhao · 10 days ago
  33. f83251a [fix][broker] Support namespace unsubscribe when bundles are unloaded (#25276) by Hao Zhang · 13 days ago
  34. 629ddeb [fix] Fix typos in class Message and Producer (#25265) by Hm · 13 days ago
  35. e44f36a [fix][ws] Fix issue where metadataStoreAllowReadOnlyOperations setting is ignored by WebSocket server (#25281) by Masahiro Sakamoto · 14 days ago
  36. e1afa05 [feat] PIP-454: Metadata Store Migration Framework (implementation) (#25219) by Matteo Merli · 14 days ago
  37. d992dc5 [fix][sec] Upgrade Jackson version to 2.18.6 (#25264) by Oneby Wang · 2 weeks ago
  38. 4cbe124 [improve][broker] Optimize AsyncTokenBucket overflow solution further to reduce fallback to BigInteger (#25269) by Lari Hotari · 3 weeks ago
  39. c27ec7d [feat][broker] add topic-level subscription expiration time policy (#25258) by Penghui Li · 3 weeks ago
  40. 6b87357 [improve][client] Support protobuf v4 schema compatibility (#25261) by Penghui Li · 3 weeks ago
  41. d207d9c [fix][broker] Guard AsyncTokenBucket against long overflow (#25262) by Penghui Li · 3 weeks ago
  42. 82846e5 [fix][broker] Use compatible Avro name validator in JsonSchemaCompatibilityCheck (#25255) by Qiang Zhao · 3 weeks ago
  43. ee477cc [fix][sec] Upgrade aircompressor to 2.0.3 to resolve CVE-2025-67721 (#25256) by Lari Hotari · 3 weeks ago
  44. 93baabe [feat][pip] PIP-454: Metadata Store Migration Framework (#25196) by Matteo Merli · 3 weeks ago
  45. 3cd3893 [fix][broker] Use compatible Avro name validator to allow '$' in schema record names (#25193) by Qiang Zhao · 3 weeks ago
  46. 82fcb18 [improve] replace jcip annotations to jsr305 annotations (#25252) by sindhushreem25 · 3 weeks ago
  47. 1f86c24 [fix][client] Reduce logging in OAuth auth to fix parsing of Pulsar cli command output (#25254) by Lari Hotari · 3 weeks ago
  48. 62e7ebc [improve] Upgrade RoaringBitmap to 1.6.9 version (#25253) by Lari Hotari · 3 weeks ago
  49. 436ca72 [improve][fn] Upgrade Pulsar Python client version to 3.10.0 (#25251) by Lari Hotari · 4 weeks ago
  50. 163b900 [fix][sec] Upgrade Python protobuf version to 6.33.5 to address CVE-2026-0994 (#25250) by Lari Hotari · 4 weeks ago
  51. 24eba10 [fix][meta] Metadata cache refresh might not take effect (#25246) by Yunze Xu · 4 weeks ago
  52. 48774de [fix][test] Fix ResourceQuotaCalculatorImplTest#testNeedToReportLocalUsage (#25247) by Yunze Xu · 4 weeks ago
  53. 9db31cc [fix][test] fix testBatchMetadataStoreMetrics. (#25241) by zzb · 5 weeks ago
  54. 4a88612 [feat][broker] PIP-452: Customizable topic listing of namespace with properties (#25160) by Cong Zhao · 5 weeks ago
  55. 1db61ac [improve][broker] Enhance advertised address resolution with fallback to localhost (#25238) by Zixuan Liu · 5 weeks ago
  56. 6b567e9 [improve][pip] PIP-447: Customizable Prometheus Labels for Topic Metrics (#25161) by Cong Zhao · 5 weeks ago
  57. d5145e4 [fix][sec] Override msgpack-core to 0.9.11 to address CVE-2026-21452 (#25233) by guptas6est · 5 weeks ago
  58. db91b93 [improve] Upgrade Netty to 4.1.131.Final (#25232) by Lari Hotari · 5 weeks ago
  59. 9740408 [feat][pip] PIP-452: Customizable topic listing of namespace with properties (#25134) by Cong Zhao · 5 weeks ago
  60. 0e5d424 [fix][broker] Fix transactionMetadataFuture completeExceptionally with null value (#25231) by Hao Zhang · 5 weeks ago
  61. f42cd25 [fix][client] Send all chunkMessageIds to broker for redelivery (#25229) by cai minjian · 5 weeks ago
  62. 0a0ce6d [improve][broker] Give the detail error msg when authenticate failed with AuthenticationException (#25221) by Jiwei Guo · 5 weeks ago
  63. c93dd7a [fix][test] Fix Mockito stubbing race in TopicListServiceTest (#25227) by sinan liu · 5 weeks ago
  64. c2ae180 [fix][broker] Fix incomplete futures in topic property update/delete methods (#25228) by Cong Zhao · 5 weeks ago
  65. 6c79d3a [improve][test] Set k8s test retry count to 0 (#25230) by Philipp Dolif · 5 weeks ago
  66. 63220ea [improve][broker] Add idle timeout support for http (#25224) by Zixuan Liu · 6 weeks ago
  67. 3cb7a7b [improve][client] Make authorization server metadata path configurable in AuthenticationOAuth2 (#25052) by Hideaki Oguni · 6 weeks ago
  68. bae9173 [improve][broker] Add strictAuthMethod to require explicit authentication method (#25185) by Omar Yasin · 6 weeks ago
  69. 2d6ef6f [fix][broker] Fix httpProxyTimeout config (#25223) by Zixuan Liu · 6 weeks ago
  70. 00a65e3 [improve][broker] Change log level from warn to debug when cursor mark-deleted position ledger doesn't exist (#25200) by Yike Xiao · 6 weeks ago
  71. 6f4ac21 [feat][io] implement pip-297 for jdbc sinks (#25195) by Bäm · 6 weeks ago
  72. e160b1a [improve][admin] Add client side looping to analyze-backlog in Topics to avoid potential HTTP call timeout (#25127) by Oneby Wang · 6 weeks ago
  73. 6433309 [fix][sec] Upgrade OpenSearch to 2.19.4 to remediate CVE-2025-9624 (#25206) by guptas6est · 6 weeks ago
  74. 2e06cc0 [fix][broker] Prevent missed topic changes in topic watchers and schedule periodic refresh with patternAutoDiscoveryPeriod interval (#25188) by Lari Hotari · 6 weeks ago
  75. 6d957646 [fix][test] Use AtomicBoolean.compareAndSet() to guarantee atomicity in testDoIndividualBatchAckNeverAffectIsDuplicate() method (#25217) by Oneby Wang · 6 weeks ago
  76. 611efe4 [fix][client] Fix producer synchronous retry handling in failPendingMessages method (#25207) by Malla Sandeep · 6 weeks ago
  77. 827bc4f [improve][io] Set default connector class for debezium connectors (#25215) by jiangpengcheng · 6 weeks ago
  78. 6d51f88 [fix][broker]Fix ledgerHandle failed to read by using new BK API (#25199) by fengyubiao · 6 weeks ago
  79. bea6f8a [fix][broker] Fix ManagedCursorImpl.asyncDelete() method may lose previous async mark delete properties in race condition (#25165) by Oneby Wang · 6 weeks ago
  80. 257d42f [fix][test]Fix flaky ExtensibleLoadManagerImplTest_testGetMetrics (#25216) by fengyubiao · 6 weeks ago
  81. e8fedb1 [improve][proxy] Add regression tests for package upload with 'Expect: 100-continue' (#25211) by Zixuan Liu · 6 weeks ago
  82. 3dc1fd6 [cleanup][doc]Remove TRACING.md as it has been moved to pulsar-site (#25213) by Penghui Li · 6 weeks ago
  83. 6d415c6 [improve][meta] PIP-453: Improve the metadata store threading model (#25187) by Yunze Xu · 6 weeks ago
  84. 5aab2f0 [fix][client] Fix race condition between isDuplicate() and flushAsync() method in PersistentAcknowledgmentsGroupingTracker due to incorrect use Netty Recycler (#25208) by Oneby Wang · 6 weeks ago
  85. 4add84c [fix] [test] Upgrade docker-java to 3.7.0 (#25209) by Matteo Merli · 6 weeks ago
  86. cab92f0 [revert] "[improve][build] Build docker image only once when pushing" (#25203) by Zixuan Liu · 6 weeks ago
  87. 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 · 6 weeks ago
  88. d630394 [fix][misc] Allow JWT tokens in OpenID auth without nbf claim (#25197) by Lari Hotari · 7 weeks ago
  89. d0efdd7 [improve][build] Build docker image only once when pushing (#25194) by Zixuan Liu · 7 weeks ago
  90. 52a4d5e [improve][client]Reduce unnecessary getPartitionedTopicMetadata requests when using retry and DLQ topics. (#25172) by zhenJiangWang · 7 weeks ago
  91. ce4ebea [fix][test] Bump org.assertj:assertj-core from 3.27.5 to 3.27.7 (#25186) by dependabot[bot] · 7 weeks ago
  92. c51346f [improve][pip] PIP-453: Improve the metadata store threading model (#25173) by Yunze Xu · 7 weeks ago
  93. b15f53b [improve][misc] Upgrade snappy version to 1.1.10.8 (#25182) by Lari Hotari · 8 weeks ago
  94. 2d04c93 [improve][misc] Upgrade to Alpine 3.23 (#25180) by Lari Hotari · 8 weeks ago
  95. 3348470 [fix][proxy] Close client connection immediately when credentials expire and forwardAuthorizationCredentials is disabled (#25179) by Zixuan Liu · 8 weeks ago
  96. f0ec07b [fix][client] ControlledClusterFailover avoid unnecessary reconnection. (#25178) by Wenzhi Feng · 8 weeks ago
  97. 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] · 8 weeks ago
  98. 9b70ba3 [fix][ml] Fix NoSuchElementException in EntryCountEstimator caused by a race condition (#25177) by Lari Hotari · 8 weeks ago
  99. 45def39 [improve][broker] Upgrade bookkeeper to 4.17.3 (#25166) by Yong Zhang · 8 weeks ago
  100. 7b87a6a [fix][build] Fix Eclipse/VSCode support after Jetty 12 upgrade (#25169) by Lari Hotari · 8 weeks ago