Google Git Google Git
Sign in
apache/pulsar/HEAD
  1. fe9a840 [fix][sec] Upgrade zstd-jni to 1.5.7-25 (#27186) by Lari Hotari · 4 hours ago master
  2. e917ab4 [fix][sec] Upgrade OkHttp to 5.5.1 and Okio to 3.18.2 (#27191) by Lari Hotari · 4 hours ago
  3. 3817195 [improve][broker] Avoid regex splitting in topic-list filtering (#27143) by Penghui Li · 5 hours ago
  4. 781f2d4 [fix][test] Fix flaky ManagedLedgerTest.testManagedLedgerWithCreateLedgerTimeOut (#27194) by Lari Hotari · 6 hours ago
  5. ce0ff92 [fix][test] Fix flaky DeadLetterTopicTest.testPossibleToDeadLetterEntryIsRemovedWhenRedeliveringABatchMessageId (#27152) by Prakarsh · 6 hours ago
  6. 2ac7307 [fix][sec] Upgrade Gson to 2.15.0 (#27192) by Lari Hotari · 7 hours ago
  7. 7d0c964 [fix][sec] Upgrade OpenTelemetry to 1.67.0 and OpenTelemetry instrumentation to 2.33.1 (#27188) by Lari Hotari · 7 hours ago
  8. 23960c3 [fix][sec] Upgrade Byte Buddy to 1.18.16 (#27193) by Lari Hotari · 7 hours ago
  9. f708657 [fix][sec] Upgrade commons-codec to 1.23.0 (#27190) by Lari Hotari · 7 hours ago
  10. c8c6395 [fix][sec] Upgrade lz4-java to 1.12.1 (#27187) by Lari Hotari · 8 hours ago
  11. 9abb543 [fix][sec] Upgrade JLine to 4.4.8 (#27189) by Lari Hotari · 8 hours ago
  12. 43c1961 [fix][sec] Upgrade java-jwt to 4.6.2 and fail OIDC authentication on out-of-range timestamps (#27185) by Lari Hotari · 8 hours ago
  13. b5f5692 [fix][sec] Upgrade snappy-java to 1.1.10.12 (#27184) by Lari Hotari · 9 hours ago
  14. 68e186c [improve][build] Upgrade gRPC to 1.85.1 (#27182) by Lari Hotari · 9 hours ago
  15. 618f960 [fix][sec] Upgrade Vert.x to 4.5.35 (#27183) by Lari Hotari · 9 hours ago
  16. cf21414 [improve][misc] Upgrade Jetty to 12.1.14 and Conscrypt to 2.7.0 (#27180) by Lari Hotari · 9 hours ago
  17. 0994d27 [fix][sec] Upgrade Checkstyle to 14.3.0 and use Guava 33.7.2-jre on its classpath (#27178) by Lari Hotari · 9 hours ago
  18. 32ef10a [improve][build] Upgrade Gradle to 9.8.2 (#27177) by Lari Hotari · 9 hours ago
  19. bca5a02 [fix][sec] Bump Jackson to 2.21.8 (#27181) by Lari Hotari · 9 hours ago
  20. e389c762 [fix][sec] Bump guava to 33.7.2-jre (#27156) by Lari Hotari · 25 hours ago
  21. 41adcb1 [fix][sec] Bump github.com/go-jose/go-jose/v4 from 4.1.4 to 4.1.6 in /pulsar-function-go (#27142) by dependabot[bot] · 30 hours ago
  22. aa2e7b9 [improve][broker] Make entry cache copying dynamically configurable (#27148) by fengyubiao · 30 hours ago
  23. 31e5c8b [fix][sec] Bump org.xerial.snappy:snappy-java from 1.1.10.8 to 1.1.10.9 (#27139) by dependabot[bot] · 30 hours ago
  24. 73c75fe [fix][sec] Use guava 33.7.1-jre also in jclouds-shaded (#27138) by dependabot[bot] · 34 hours ago
  25. 8068695 [fix][admin] Fix Pulsar Admin client deadlock caused by AsyncHttpClient's per-host connection limit (#27144) by Penghui Li · 34 hours ago
  26. 4424ea0 [fix][broker] Prevent dispatch rate limiting overshoot with batched messages (#27022) by Abhirama · 2 days ago
  27. 5070b28 [improve][meta] Upgrade Oxia Java client to 0.10.3 (#27141) by Qiang Zhao · 2 days ago
  28. bc99ae9 [improve][build] Replace grpc-netty-shaded with grpc-netty (#27131) by Lari Hotari · 2 days ago
  29. dcec727 [fix][broker] Return errors for discarded ACKs with receipts (#27128) by Aurora Twinkle · 2 days ago
  30. 23a3b40 [improve][doc] Document TopicName#isPartitioned and clarify getPartitionedTopicName (#27103) by gibkim · 2 days ago
  31. fee462c [improve][cli] Show the compression type when peeking or examining messages (#27119) by gibkim · 2 days ago
  32. f5c2acf [improve][cli] Support compacted reads in client commands (#27100) by Aurora Twinkle · 2 days ago
  33. fadf061 [fix][broker] Clear pending read flags when a read fails before the cursor takes ownership (#27059) by Zixuan Liu · 2 days ago
  34. 489e2f9 [improve][broker] Balance partitions across consumers with activeConsumerFailoverConsistentHashing (#27125) by Penghui Li · 3 days ago
  35. b02b041 [fix][ml] Fix ManagedCursor missing active-cursor registration during concurrent state changes (#27107) by void-ptr974 · 3 days ago
  36. 0ba3045 [fix][client] Fail creation on explicit TLS client certificate alerts (#27102) by Aurora Twinkle · 3 days ago
  37. ffd1636c [fix][client] Fix new topics and partitions not receiving messages after resume (#27063) by void-ptr974 · 3 days ago
  38. 5e7633c0 [improve][meta] Upgrade Oxia Java client to 0.10.2 (#27124) by Qiang Zhao · 3 days ago
  39. a36cd17 [fix][client][txn] Fix client connection closed before using (#22749) by 道君- Tao Jiuming · 3 days ago
  40. 5188833 [fix][client] Don't clear shared broker entry metadata when recycling a pooled message (#27098) by sakshichitnis27 · 3 days ago
  41. 86c6012 [fix][broker] Fix Key_Shared replay hash count races during mark-delete cleanup (#27109) by void-ptr974 · 3 days ago
  42. 0243c6c [fix][test] Fix flaky ZKMetadataStoreBatchIOperationTest.testReceivedHugeResponse (#27122) by Lari Hotari · 3 days ago
  43. ae082c1 [cleanup][misc] Fix the remaining javac warnings in main sources (#27113) by Matteo Merli · 3 days ago
  44. a362972 [cleanup][test] Fix deprecation warnings in tests (#27117) by Matteo Merli · 3 days ago
  45. 5a098d3 [cleanup][test] Replace the deprecated URL(String) constructor in tests (#27115) by Matteo Merli · 3 days ago
  46. f61afc4 [cleanup][build] Put swagger annotations on test compile classpaths to fix RequiredMode javac warnings (#27114) by Matteo Merli · 3 days ago
  47. 51c6215 [cleanup][test] Replace Netty's deprecated NioEventLoopGroup and DefaultEventLoopGroup in tests (#27116) by Matteo Merli · 3 days ago
  48. 9705414 [cleanup][test] Fix unchecked warnings in tests (#27118) by Matteo Merli · 3 days ago
  49. f0a6b6c [fix][test] Fix Mockito stubbing race in NamespaceServiceSplitFailureTest (#27090) by Matteo Merli · 3 days ago
  50. 23b1264 [fix][client] Keep non-serialized builder settings across loadConf (#27086) by Matteo Merli · 3 days ago
  51. bb79dcc [cleanup][misc] Fix javac deprecation and unchecked warnings in main sources (#26257) by Ali Ahmed · 4 days ago
  52. 3df91ba [fix][client] Preserve pooled heap message data across repeated reads (#27097) by Aurora Twinkle · 4 days ago
  53. 9cbb6d9 [improve][test] Reduce SchemaServiceTest wall time from 152.5s to 75.0s (#27092) by void-ptr974 · 5 days ago
  54. 9c41d0c [fix][build] Upgrade RoaringBitmap to 1.6.25 to fix LongBitmap range contains and previousAbsentValue (#27095) by LiuYC3213687107 · 5 days ago
  55. a038d6b [fix][client] Fix double-counted permits when the receiver queue grows during reconnect (#27068) by void-ptr974 · 5 days ago
  56. 1733139 [improve][pip] PIP-273: Enable hostname verification by default (#20453) by Michael Marshall · 6 days ago
  57. 5b53713 [fix][ml] Discard a ledger created after its creation was given up on (#16647) by lordcheng10 · 6 days ago
  58. 108d58d [improve][broker] Add http produce backlog quota check (#25189) by Dream95 · 6 days ago
  59. 0dfc5d8 [fix][client] Fail transaction coordinator requests after close instead of throwing NullPointerException (#27078) by Matteo Merli · 6 days ago
  60. 8ed1409 [fix][client] Ignore superseded subscribe and producer attempts (#27081) by Matteo Merli · 6 days ago
  61. 1c5ff9a [fix][ws] Release WebSocket consumer pending slots only for pending message ids (#27083) by Matteo Merli · 6 days ago
  62. 8f322f6 [fix][client] Flush the pending acks before the zero-queue permits on reconnect (#27087) by Matteo Merli · 6 days ago
  63. a0e7f7d [improve][fn] Support OAuth2 in Go instance (#22323) by jiangpengcheng · 6 days ago
  64. de943bc [improve][txn] Allow transaction owners to abort their own transactions via the abortTransaction admin API (#22978) by hrzzzz · 6 days ago
  65. 67a5e6c [fix][client] Fail pending transaction coordinator requests when TransactionMetaStoreHandler closes (#27073) by Matteo Merli · 6 days ago
  66. fc19791 [fix][txn] Keep plain publishes behind the transactional ones TopicTransactionBuffer holds back (#27082) by Matteo Merli · 6 days ago
  67. 02efae5 [fix][broker] Retry the dedup cursor delete after a failure while disabling at topic load (#15363) by fengyubiao · 6 days ago
  68. 530e589 [fix][client] Fix DLQ sending a released message when poolMessages is enabled (#13280) by WangJialing · 6 days ago
  69. eeb818b [fix][broker] Start packages management before the function worker service (#16502) by Lan · 6 days ago
  70. 1c5a190 [fix][cli] Make pulsar-perf consume and transaction end and await every transaction they open (#27084) by Matteo Merli · 6 days ago
  71. 0999253 [fix][broker] Close the existing consumer when the same consumer subscribes again (#20737) by fengyubiao · 6 days ago
  72. 8b8436b [fix][client] Keep non-transactional messages out of transactional batches on scalable topics (#27079) by Matteo Merli · 6 days ago
  73. aa2a681 [fix][txn] Keep plain publishes to scalable-topic segments behind pending transactional ones (#27080) by Matteo Merli · 6 days ago
  74. 852c2c1 [Functions] fix upload nar file to start function task failed (#16133) by yangguodong · 6 days ago
  75. 1fc58c5 [fix][broker] Keep the bundle affinity broker for every lookup until the bundle is owned (#19260) by lixinyang · 6 days ago
  76. b624352 [fix][admin] Read the error response body once when extracting the server's reason (#18937) by Yang Yang · 6 days ago
  77. 4a2dafb [fix][broker] Don't share the dispatcher's FilterContext with analyzeBacklog (#20246) by lifepuzzlefun · 6 days ago
  78. 1ae28a2 [improve][admin] Include schema ledger ids in topic internal-info (#19883) by Rajan Dhabalia · 6 days ago
  79. 63cca3c [fix][broker] Fall back to the broker isolation groups after a namespace bookie affinity group is removed (#16325) by lixinyang · 6 days ago
  80. 6efa84a [fix][broker] Don't count the target namespace in its own anti-affinity group (#16563) by lixinyang · 6 days ago
  81. fc29d92 [fix][cli] Make pulsar-perf produce end and await every transaction it opens (#27077) by Matteo Merli · 6 days ago
  82. 4fc01a6 [fix][client] Fix consumer discarding all messages after redelivering during a reconnection (#20032) by congbo · 6 days ago
  83. 0a01a5c [fix][client] Fix pattern consumers that stop updating topics when subscribing to a new topic fails (#27066) by void-ptr974 · 6 days ago
  84. 73f70bc [fix][client] Fix stale batch ACKs causing skipped messages after seek (#27067) by void-ptr974 · 6 days ago
  85. b9a2b2d [fix][client] Flush the pending acks before the flow command when the consumer reconnects (#27062) by SeungTaek Lim · 6 days ago
  86. 18383da [improve][admin] Validate dynamic configuration updates against FieldContext constraints (#26087) by Dream95 · 6 days ago
  87. 0193ca5f [fix] [client] NotifyPendingReceivedCallback when zeroConsumerImpl received batch message firstly then close consumer (#15144) by Yan Zhao · 6 days ago
  88. 31267f9 [fix][test] Fix flaky V5CumulativeAckTest.testRetryingAnAckThatFailedWhileDisconnectedAdvancesTheCursor (#27070) by Matteo Merli · 6 days ago
  89. a63a949 [fix][txn] Treat a concurrent duplicate transaction status update as success (#20053) by ken · 6 days ago
  90. eb86d61 [improve][misc] PIP-351: Add options to Pulsar-Test client to support KeyStore based TLS (#27058) by Matteo Merli · 6 days ago
  91. 633511a [fix][broker] Copy subscriptions to the partitions created by createMissedPartitions (#17946) by HuangZeGui · 6 days ago
  92. a06fe80 [improve][fn] PIP-237: Expose PulsarAdmin in SinkContext and SourceContext (#19679) by Alexander Preuß · 6 days ago
  93. d0c1ee0 [improve][client] Log the stack trace when MessageCryptoBc fails to load a key or encrypt/decrypt a data key (#19867) by Rajan Dhabalia · 6 days ago
  94. e3dd37b [fix][ml] Fix off-by-one backlog of cursors created while an entry is being added (#19352) by fengyubiao · 6 days ago
  95. d51ff7a [fix][client] Stop the partition update timer of a partitioned producer that ended during creation (#27061) by SeungTaek Lim · 6 days ago
  96. 7538399 [fix][fn] Use TLS urls for the embedded function worker when brokerClientTlsEnabled is set (#21013) by Zixuan Liu · 6 days ago
  97. fa55275 [fix][meta] Reload the bookie info on a cache miss in PulsarRegistrationClient (#27052) by Matteo Merli · 6 days ago
  98. b25f6e2 [fix][client] Make ackTimeoutRedeliveryBackoff work on Exclusive and Failover subscriptions (#19602) by Cong Zhao · 6 days ago
  99. 4c760b6 [fix][ml] Fix the estimated backlog of lazily recovered cursors (#27060) by Matteo Merli · 6 days ago
  100. 17166c8 [fix][proxy] Copy GetTopicsOfNamespace properties before the broker connection completes (#27055) by Lari Hotari · 7 days ago