Google Git
Sign in
apache / pulsar / HEAD
  1. 0c6ba1c [fix][test] Flaky-test: BrokerServiceTest.testShutDownWithMaxConcurrentUnload (#24769) by Yike Xiao · 2 days ago master
  2. 8f995b2 [improve][build] Upgrade SpotBugs to a version that supports JDK25 (#24768) by Lari Hotari · 2 days ago
  3. 735c920 [fix][ci] Fix CI for Java 25 including upgrade of Gradle Develocity Maven extension (#24767) by Lari Hotari · 2 days ago
  4. e94755d [improve][build] Upgrade Mockito, AssertJ and ByteBuddy to fully support JDK25 (#24764) by Lari Hotari · 2 days ago
  5. b11f05f [fix][client] Exclude io.prometheus:simpleclient_caffeine from client-side dependencies (#24761) by Lari Hotari · 2 days ago
  6. e45f3af [improve][build] Upgrade Lombok to 1.18.42 to fully support JDK25 (#24763) by Lari Hotari · 2 days ago
  7. d833b8b [improve][broker] If there is a deadlock in the service, the probe should return a failure because the service may be unavailable (#23634) by yangyijun · 2 days ago
  8. 8879b3ba [feat][pip] PIP-442: Add memory limits for CommandGetTopicsOfNamespace and CommandWatchTopicList on Broker and Proxy (#24727) by Lari Hotari · 3 days ago
  9. 7a120f3 [fix][broker] First entry will be skipped if opening NonDurableCursor while trimmed ledger is adding first entry. (#24738) by zhouyifan279 · 3 days ago
  10. ccbd245 [fix][broker] Prevent unexpected recycle failure in dispatcher's read callback (#24741) by Yunze Xu · 4 days ago
  11. 5baaabc [fix][broker] Fix typos in PulsarClusterMetadataSetup (#24750) by Wonyong Hwang · 4 days ago
  12. 63331ca [fix][broker] Fix testServiceConfigurationRetentionPolicy unit test (#24756) by Oneby · 4 days ago
  13. 1300f0a [fix][client] rollback TopicListWatcher retry behavior (#24752) by Oneby · 4 days ago
  14. 437d9f6 [improve][broker] Allow deletion of empty persistent topics regardless of retention policy (#24733) by Penghui Li · 5 days ago
  15. c461589 [fix] Exclude commons-lang dep from bookkeeper (#24749) by Matteo Merli · 5 days ago
  16. 8e35e34 [fix][client] Fix receiver queue auto-scale without memory limit (#24743) by Philipp Dolif · 6 days ago
  17. 831740c [improve][build] Upgrade Apache Parent POM to version 35 (#24742) by Lari Hotari · 6 days ago
  18. e417aca [fix][ml] Negative backlog & acked positions does not exist & message lost when concurrently occupying topic owner (#24722) by fengyubiao · 6 days ago
  19. e73532a [fix][broker] Ensure KeyShared sticky mode consumer respects assigned ranges (#24730) by Baodi Shi · 7 days ago
  20. 80beab6 [fix][broker] Key_Shared subscription doesn't always deliver messages from the replay queue after a consumer disconnects and leaves a backlog (#24736) by nborisov · 9 days ago
  21. 8d7a28c [fix][client] Fix PulsarAdmin description check and add test (#24734) by Zixuan Liu · 9 days ago
  22. 4169395 [fix][broker] Fix cannot shutdown broker gracefully by admin api (#24731) by Yike Xiao · 10 days ago
  23. e19856a [improve][client] Allow adding custom description to User-Agent header (#24729) by Zixuan Liu · 10 days ago
  24. a824f04 [fix][io] Improve Kafka Connect source offset flushing logic (#24654) by Harangozó Péter · 10 days ago
  25. 14543d3 [fix][client] Avoid recycling the same ConcurrentBitSetRecyclable among different threads (#24725) by Yunze Xu · 10 days ago
  26. 1cb64a9 [fix][broker]Fix never recovered metadata store bad version issue if received a large response from ZK (#24580) by fengyubiao · 10 days ago
  27. 65b3541 [fix][client] Add description method to ClientBuilder (#24728) by Zixuan Liu · 11 days ago
  28. 415c6fa [feat][fn] Fallback to using `STATE_STORAGE_SERVICE_URL` in `PulsarMetadataStateStoreProviderImpl.init` (#24721) by jiangpengcheng · 11 days ago
  29. 7547fab [improve][pip] PIP-437: Granular and Fixed-Delay Policies for Message Delivery (#24625) by Christina Wang · 12 days ago
  30. 53bbd4a [improve][broker] Reduce unnecessary MessageMetadata parsing by caching the parsed instance in the broker cache (#24682) by Lari Hotari · 12 days ago
  31. 9715653 [fix][broker] Fix memory leak when metrics are updated in a thread other than FastThreadLocalThread (#24719) by Yunze Xu · 12 days ago
  32. a2b69cc [fix][broker]Dispatcher did unnecessary sort for recentlyJoinedConsumers and printed noisy error logs (#24634) by fengyubiao · 12 days ago
  33. 90b2aac [improve][pip] PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when channel is unwritable (#24510) by fengyubiao · 13 days ago
  34. 0cda4f4 [improve][broker] Optimize Reader creation in TopicPoliciesService (#24658) by 道君- Tao Jiuming · 13 days ago
  35. c7dff63 [improve][io] Upgrade to Debezium 3.2.2 (#24712) by Enrique Fernández · 13 days ago
  36. e9a9e04 [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24717) by Lari Hotari · 13 days ago
  37. 465281c [fix][test]fix flaky MessagePayloadProcessorTest.testDefaultProcessor (#24710) by Ruimin MA · 13 days ago
  38. 783172f [improve][build] Disable javadoc build failure (#24594) by Zixuan Liu · 13 days ago
  39. 56399ee [improve][misc] Protect branch-4.1 (#24715) by Lari Hotari · 13 days ago
  40. 0a949de [improve][build] docker: use up to date wolfi-base location (#24708) by Dimitri John Ledkov · 2 weeks ago
  41. 77b34cc [improve][test] Improve integration test profiling test example (#24701) by Lari Hotari · 2 weeks ago
  42. cc824e5 [fix][client]TopicListWatcher not closed when calling PatternMultiTopicsConsumerImpl.closeAsync() method (#24698) by Oneby · 2 weeks ago
  43. e6f66df [fix][broker] Fix NPE and annotate nullable return values for ManagedCursorContainer (#24706) by Yunze Xu · 2 weeks ago
  44. 536dce3 [improve][client] PIP-407 Add newMessage with schema and transactions (#23942) by Omar Yasin · 2 weeks ago
  45. 669ab61 [improve][ml] Improve cache insert performance by removing exists check since it's already covered by putIfAbsent (#24699) by Lari Hotari · 3 weeks ago
  46. 96bc370 [fix][broker]Fix dirty reading of namespace level offload thresholds (#24696) by fengyubiao · 3 weeks ago
  47. 2e6a8eb [improve][build] Support building docker images that use Wolfi base image which is glibc based (#24692) by Lari Hotari · 3 weeks ago
  48. fcd5f92 [feat][misc] upgrade oxia version to 0.6.2 (#24689) by Qiang Zhao · 3 weeks ago
  49. f1b66ae [improve][doc] Clarify geo-replication cluster removal behavior for shared vs separate configuration stores (#24687) by Penghui Li · 3 weeks ago
  50. 41f2cd4 [fix][build] Set project version to 4.2.0-SNAPSHOT (#24690) by Cong Zhao · 3 weeks ago
  51. 5e9e912 [fix][client] Fix potential NPE in TypedMessageBuilderImpl (#24691) by ran · 3 weeks ago
  52. 0903f45 [fix][broker] Pass metadataStoreSessionTimeoutMillis to bookkeeper client configuration to properly configure ZK timeout (#24624) by Zhangao · 3 weeks ago
  53. 82f2371 [fix][broker]Fix the wrong logic of the test PartitionCreationTest.testCreateMissedPartitions (#24683) by fengyubiao · 3 weeks ago
  54. 413bfe7 [improve][build] Add Async Profiler integration for integration tests (#24688) by Lari Hotari · 3 weeks ago
  55. 45d71f8 [improve][client] PIP-420: Supports users implement external schemas (#24488) by ran · 3 weeks ago
  56. 4a4e692 [improve][doc] Cleanup some legacy PIP documents and improve PIP listing (#24684) by Lari Hotari · 3 weeks ago
  57. e466f45 [improve] [pip] PIP-382: Add a label named reason for topic_load_failed_total (#23351) by fengyubiao · 3 weeks ago
  58. 66b69ad [fix][broker]User topic failed to delete after removed cluster because of failed delete data from transaction buffer topic (#24648) by fengyubiao · 3 weeks ago
  59. f767149 [improve] [pip] PIP-375 Expose the Admin client configs: readTimeout, requestTimeout, and connectionTimeout (#23222) by fengyubiao · 3 weeks ago
  60. 8fd5bf5 [fix][client] Fix ArrayIndexOutOfBoundsException when using SameAuthParamsLookupAutoClusterFailover (#23336) by fengyubiao · 3 weeks ago
  61. 03e0787 [improve][test]Add new test PartitionCreationTest.testGetPoliciesIfPartitionsNotCreated (#24681) by fengyubiao · 3 weeks ago
  62. a035c6e [improve][doc] Update PIP links in PIP documents converted from the wiki and remove trailing whitespace (#24678) by Lari Hotari · 3 weeks ago
  63. f795bf8 [fix][broker]Fix flaky test PartitionCreationTest.testCreateMissedPartitions (#24679) by fengyubiao · 3 weeks ago
  64. 490ba0c [improve][broker] Implement PIP-430 Pulsar Broker cache improvements (#24623) by Lari Hotari · 4 weeks ago
  65. 84205eb [improve][broker]Find the target position at most once, during expiring messages for a topic, even though there are many subscriptions (#24622) by fengyubiao · 4 weeks ago
  66. 7c57683 [fix][broker]Failed to create partitions after the partitions were deleted because topic GC (#24651) by fengyubiao · 4 weeks ago
  67. 90a70db [fix][meta] Use `getChildrenFromStore` to read children data to avoid lost data (#24665) by Jiwei Guo · 4 weeks ago
  68. a532798 [fix][broker] Invalid regex in PulsarLedgerManager causes zk data notification to be ignored (#23977) by ken · 4 weeks ago
  69. 829df71 [fix][client] Skip schema validation when sending messages to DLQ to avoid infinite loop when schema validation fails on an incoming message (#24663) by Ruimin MA · 4 weeks ago
  70. 3b7bef1 [improve][io] Support specifying Kinesis KPL native binary path with 1.0 version specific path (#24669) by Lari Hotari · 4 weeks ago
  71. a239240 [improve][build] Use org.apache.nifi:nifi-nar-maven-plugin:2.1.0 with skipDocGeneration=true (#24668) by Lari Hotari · 4 weeks ago
  72. 19f9c26 [improve][build] Increase maven resolver's sync context timeout (#24666) by Zixuan Liu · 4 weeks ago
  73. e5e7981 [fix][broker] PIP-428: Fix corrupted topic policies issues with sequential topic policy updates (#24427) by Lari Hotari · 4 weeks ago
  74. dc2ab26 [improve][io] Upgrade AWS SDK v1 & v2, Kinesis KPL and KPC versions (#24661) by Lari Hotari · 4 weeks ago
  75. 95dcb58 [fix][client] fix ArrayIndexOutOfBoundsException in SameAuthParamsLookupAutoClusterFailover (#24662) by pmupkin · 4 weeks ago
  76. da0d116 [improve][ml] Optimize ledger opening by skipping fully acknowledged ledgers (#24655) by Cong Zhao · 4 weeks ago
  77. f2709bc [improve][doc] Add all legacy PIPs from Pulsar wiki and GitHub issues as files to pip directory (#24660) by Lari Hotari · 4 weeks ago
  78. b1ba220 [fix][misc] Upgrade fastutil to 8.5.16 (#24659) by Lari Hotari · 4 weeks ago
  79. 738b519 [improve][pip] Standardize PIP filenames and add comprehensive table of contents (#24653) by Penghui Li · 4 weeks ago
  80. d3c615c [fix][broker] Fix race condition in MetadataStoreCacheLoader causing inconsistent availableBroker list caching (#24639) by zzb · 5 weeks ago
  81. cb56281 [improve][pip]PIP-436: Add decryptFailListener to Consumer (#24572) by Ruimin MA · 5 weeks ago
  82. a66e806 [improve][client] Add OpenTelemetry metrics for client memory buffer usage (#24647) by Penghui Li · 5 weeks ago
  83. 3c70e09 [fix][offload] Exclude unnecessary dependencies from tiered storage provider / offloader nar files (#24649) by Lari Hotari · 5 weeks ago
  84. e78068a [fix][sec] Upgrade bouncycastle bcpkix-fips version to 1.79 to address CVE-2025-8916 (#24650) by Lari Hotari · 5 weeks ago
  85. e642e17 [fix][broker] Add double-check for non-durable cursor creation (#24643) by Zixuan Liu · 5 weeks ago
  86. 34f8657 [fix][ws] Allow websocket principals to specify originalPrincipal without proxy role (#24642) by Penghui Li · 5 weeks ago
  87. 64137f6 [fix][sec] Upgrade to Netty 4.1.124.Final to address CVE-2025-55163 (#24637) by Lari Hotari · 5 weeks ago
  88. 65607ab [fix][test]fix flaky ZeroQueueSizeTest.testZeroQueueGetExceptionWhenReceiveBatchMessage (#24633) by Ruimin MA · 5 weeks ago
  89. 19b7c27 [fix][test] Fix ConcurrentModificationException in Ipv4Proxy (#24632) by Philipp Dolif · 5 weeks ago
  90. ba4f715 [fix][test]fix flaky ZeroQueueSizeTest.testZeroQueueGetExceptionWhenReceiveBatchMessage (#24630) by Ruimin MA · 5 weeks ago
  91. 99535a6 [feat][pip] PIP-420: Provide ability for Pulsar clients to integrate with third-party schema registry service (#24328) by ran · 5 weeks ago
  92. cde4948 [fix][proxy] Fix TooLongFrameException with Pulsar Proxy (#24626) by Lari Hotari · 5 weeks ago
  93. e7fe889 [fix][broker] Fix duplicate watcher registration after SessionReestablished (#24621) by hrzzzz · 6 weeks ago
  94. baa288a [improve][broker] Upgrade avro version to 1.12.0 (#24617) by Hang Chen · 6 weeks ago
  95. bbf56f6 [fix][client]Prevent ZeroQueueConsumer from receiving batch messages when using MessagePayloadProcessor (#24610) by Ruimin MA · 6 weeks ago
  96. 277835a [improve][build] Skip top level hidden directories from license check and add instructions about AI tool directories (#24614) by Lari Hotari · 6 weeks ago
  97. fee8693 [fix][ws] Fix WebSocket authentication with authenticateOriginalAuthData enabled (#24615) by Penghui Li · 6 weeks ago
  98. ed10ec3 [improve][broker]Part-2 Add Admin API to delete topic policies (#24602) by fengyubiao · 6 weeks ago
  99. c3c55a7 [fix][ws] Fix WebSocket proxy originalPrincipal for HTTP admin API calls (#24613) by Penghui Li · 6 weeks ago
  100. 3d57c60 [fix][misc] Exclude commons-configuration2 and commons-beanutils in pulsar-common (#24612) by Lari Hotari · 6 weeks ago