Google Git
Sign in
apache / pulsar / HEAD
  1. 253e650 [fix][broker] Fix ProducerBusy issue due to incorrect userCreatedProducerCount on non-persistent topic (#22685) by hrzzzz · 10 hours ago master
  2. bed032e [improve] [broker] Add additionalSystemCursorNames ignore list for TTL check (#22614) by Hang Chen · 11 hours ago
  3. 0fd223d [improve] [pip] PIP-349: Add additionalSystemCursorNames ignore list for TTL check (#22651) by Hang Chen · 14 hours ago
  4. 03a4995 [improve][offload] Replace usage of shaded class in OffsetsCache (#22683) by Lari Hotari · 14 hours ago
  5. 566330c [fix][offload] Fix OOM in tiered storage, caused by unbounded offsets cache (#22679) by Lari Hotari · 16 hours ago
  6. bd4c57d [fix][broker] Fix geo-replication admin client url (#22584) by Kai Wang · 18 hours ago
  7. 8f015d8 [fix][broker] usedLocallySinceLastReport should always be reset (#22672) by Zixuan Liu · 22 hours ago
  8. 88feb87 [fix][ml] Remove duplicated field initialization of ML (#22676) by 道君 · 23 hours ago
  9. ad75e3f [improve][broker] Remove unused method CompactionRecord.reset (#22670) by Dragos Misca · 27 hours ago
  10. ada31a9 [fix] [broker] Fix nothing changed after removing dynamic configs (#22673) by fengyubiao · 34 hours ago
  11. 5ab0512 [fix] [broker] rename to changeMaxReadPositionCount (#22656) by Wenzhi Feng · 2 days ago
  12. ca44b9b Revert "[fix][sec] Upgrade Debezium oracle connector version to avoid… (#22668) by Lari Hotari · 2 days ago
  13. 188355b [fix][admin] Fix deprecated check (#22653) by Zixuan Liu · 2 days ago
  14. 3114199 [fix][broker] avoid offload system topic (#22497) by Qiang Zhao · 2 days ago
  15. 80d4675 [improve][ws] Add memory limit configuration for Pulsar client used in Websocket proxy (#22666) by Lari Hotari · 2 days ago
  16. e2feec8 [improve][broker] Disable JFR metric reporting in OpenTelemetry (#22669) by Dragos Misca · 2 days ago
  17. 5ff0fb9 [fix][broker] Disable system topic message deduplication (#22582) by Qiang Zhao · 2 days ago
  18. 519d8e2 [fix][broker] Add the missed opentelemetry-sdk-testing dependency to tests of pulsar-broker-auth-sasl (#22665) by Yunze Xu · 2 days ago
  19. 83b86ab [improve] Retry re-validating ResourceLock with backoff after errors (#22617) by Matteo Merli · 2 days ago
  20. 788b5ae [feat][broker] PIP-264: Add Java runtime metrics (#22616) by Dragos Misca · 2 days ago
  21. 09364a9 [improve] Upgrade to Oxia client 0.2.0 (#22663) by Matteo Merli · 2 days ago
  22. 8167554 [improve][test] Clear fields in AuthZTest classes at cleanup (#22661) by Lari Hotari · 2 days ago
  23. 7e88463 [fix] Fix Reader can be stuck from transaction aborted messages. (#22610) by 道君 · 2 days ago
  24. a7e1fcd [fix] [ml] Mark delete stuck due to switching cursor ledger fails (#22662) by fengyubiao · 3 days ago
  25. c30765e [improve][broker] Exclude producers for geo-replication from publishers field of topic stats (#22556) by Masahiro Sakamoto · 3 days ago
  26. 1e19190 [fix][broker] Fix thread safety of loadSheddingTask and loadResourceQuotaTask fields (#22660) by Lari Hotari · 3 days ago
  27. 025354e [fix][test] Clear MockedPulsarServiceBaseTest fields to prevent test runtime memory leak (#22659) by Lari Hotari · 3 days ago
  28. efcedf6 [fix][io] Fix es index creation (#22654) by Zixuan Liu · 3 days ago
  29. eee3694 [fix][storage] ReadonlyManagedLedger initialization does not fill in the properties (#22630) by Gvan Yao · 6 days ago
  30. 2821afa [improve][build] Upgrade OTel library versions (#22649) by Lari Hotari · 6 days ago
  31. 3ca4ddf [fix][sec] Upgrade elasticsearch-java version to avoid CVE-2023-4043 (#22640) by Nikhil Erigila · 6 days ago
  32. 4a59536 [fix][sec] Upgrade Debezium oracle connector version to avoid CVE-2023-4586 (#22641) by Nikhil Erigila · 6 days ago
  33. 7a8c454 [improve][broker] Add logging to leader election (#22645) by Lari Hotari · 6 days ago
  34. d12f623 [improve][build] Use slf4j-bom to align slf4j versions (#22646) by Lari Hotari · 6 days ago
  35. 0219921 [fix] [client] Fix Consumer should return configured batch receive max messages (#22619) by Rajan Dhabalia · 7 days ago
  36. 41f633f [fix][misc] NPE during standalone shutdown (#22636) by Nicolò Boschi · 7 days ago
  37. bc44280 [fix][sec] Upgrade aws-sdk.version to avoid CVE-2024-21634 (#22633) by Nikhil Erigila · 7 days ago
  38. 6f75569 [improve][cli] PIP-343: Refactor pulsar-perf to subcommand (#22388) by crossoverJie · 7 days ago
  39. 4f3cc6c [feat][broker] PIP-264: Add topic messaging metrics (#22467) by Dragos Misca · 8 days ago
  40. a904863 [fix] Test was leaving client instance to null (#22631) by Matteo Merli · 8 days ago
  41. 7daebaa [fix][ci] Fix labeler GitHub Actions workflow, adapt to v5 configuration format (#22628) by Lari Hotari · 8 days ago
  42. 084daf0 [improve][storage] Periodically rollover Cursor ledgers (#22622) by Enrico Olivelli · 9 days ago
  43. d067efc [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes (#22501) by Rui Fu · 9 days ago
  44. 0fb1a71 [improve][ci] Upgrade deprecated GitHub Actions to supported versions (#22620) by Lari Hotari · 9 days ago
  45. 340d60d [fix] [broker] Fix metrics pulsar_topic_load_failed_count is 0 when load non-persistent topic fails and fix the flaky test testBrokerStatsTopicLoadFailed (#22580) by fengyubiao · 10 days ago
  46. 6fdc0e3 [fix] [test] Fix flaky test ReplicatorTest (#22594) by fengyubiao · 11 days ago
  47. 93afd89 [fix][broker] One topic can be closed multiple times concurrently (#17524) by fengyubiao · 11 days ago
  48. 264722f [fix][test] Fix the flaky tests of ManagedLedgerImplUtilsTest (#22611) by Penghui Li · 11 days ago
  49. a761b97 [fix][broker] Reader stuck after call hasMessageAvailable when enable replicateSubscriptionState (#22572) by Baodi Shi · 11 days ago
  50. 1bb9378 [improve][test] Add policy authentication test for namespace API (#22593) by Cong Zhao · 12 days ago
  51. 5d9ccd4 [fix][test] Flaky-test: ManagedLedgerTest.testTimestampOnWorkingLedger (#22600) by Baodi Shi · 13 days ago
  52. bf5d6aa [improve][broker] perf: Reduce stickyHash calculations of non-persistent topics in SHARED subscriptions (#22536) by Andrey Yegorov · 13 days ago
  53. 8323a3c [improve][broker] Don't use forkjoin pool by default for deleting partitioned topics (#22598) by Lari Hotari · 13 days ago
  54. 7a44c80 [improve][broker] Close TopicPoliciesService to allow Pulsar broker graceful shutdown (#22589) by Lari Hotari · 13 days ago
  55. f8f256c [fix][broker] Continue closing even when executor is shut down (#22599) by Lari Hotari · 13 days ago
  56. f411e3c [fix][broker] Avoid being stuck when closing the broker with extensible load manager (#22573) by Yunze Xu · 13 days ago
  57. 3b9602c [improve][broker] Propagate cause exception in TopicBusyException when applicable (#22596) by Lari Hotari · 13 days ago
  58. 69839c7 [improve][meta] Log a warning when ZK batch fails with connectionloss (#22566) by Lari Hotari · 13 days ago
  59. d19860c [cleanup] [test] remove useless TestAuthorizationProvider2 (#22595) by thetumbled · 14 days ago
  60. 69a600e [improve][admin] Check if the topic existed before the permission operations (#22547) by Jiwei Guo · 14 days ago
  61. f25776d [fix][admin] Fix namespace admin api exception response (#22587) by Cong Zhao · 14 days ago
  62. 3de14c5 [fix][test] Clear fields in test cleanup to reduce memory consumption (#22583) by Lari Hotari · 2 weeks ago
  63. 6a94231 [improve][ci] Disable test that causes OOME until the problem has been resolved (#22586) by Lari Hotari · 2 weeks ago
  64. 997c8b9 [fix][broker] Fix BufferOverflowException and EOFException bugs in /metrics gzip compression (#22576) by Lari Hotari · 2 weeks ago
  65. 0c097ef [improve][misc] Upgrade slf4j to 2.0.13 (#22391) by Zixuan Liu · 2 weeks ago
  66. b774666 [fix] [broker] Part-2: Replicator can not created successfully due to an orphan replicator in the previous topic owner (#21948) by fengyubiao · 2 weeks ago
  67. d475655 [improve] [broker] Create partitioned topics automatically when enable topic level replication (#22537) by fengyubiao · 2 weeks ago
  68. a3cd1f8 [fix][io] CompressionEnabled didn't work on elasticsearch sink (#22565) by Baodi Shi · 2 weeks ago
  69. 77a99ed [fix] Include swagger annotations in shaded client lib (#22570) by Matteo Merli · 2 weeks ago
  70. d5c7231 [fix][admin] Fix can't delete tenant for v1 (#22550) by Jiwei Guo · 2 weeks ago
  71. 89b201e [improve][broker] Make BrokerSelectionStrategy pluggable (#22553) by Yunze Xu · 2 weeks ago
  72. 358c7cc [fix][ci] Don't allow merging PR without successful result (#22563) by Lari Hotari · 2 weeks ago
  73. 7fe92ac [fix][broker] Support lookup options for extensible load manager (#22487) by Kai Wang · 2 weeks ago
  74. 882ce41 [improve][broker] Apply loadBalancerDebugModeEnabled in LeastResourceUsageWithWeight (#22549) by Yunze Xu · 2 weeks ago
  75. 4924052 [fix] [broker] Part-1: Replicator can not created successfully due to an orphan replicator in the previous topic owner (#21946) by fengyubiao · 2 weeks ago
  76. c72c135 [improve] Update Oxia client to 0.1.6 (#22525) by Matteo Merli · 2 weeks ago
  77. a037fa3 [improve][misc] Upgrade to Bookkeeper 4.17.0 (#22551) by Lari Hotari · 2 weeks ago
  78. 35599b7 [fix][ml] Fix NPE of getValidPositionAfterSkippedEntries when recovering a terminated managed ledger (#22552) by Cong Zhao · 2 weeks ago
  79. e81f370 [fix][offload] Increase file upload limit from 2048MiB to 4096MiB for GCP/GCS offloading (#22554) by Lari Hotari · 2 weeks ago
  80. 3a0f908 [improve][test] Add topic policy test for topic API (#22546) by Jiwei Guo · 3 weeks ago
  81. 4a88721 [improve][broker] Support X-Forwarded-For and HA Proxy Protocol for resolving original client IP of http/https requests (#22524) by Lari Hotari · 3 weeks ago
  82. 21647a1 [fix] Bump golang.org/x/net from 0.17.0 to 0.23.0 in /pulsar-function-go (#22540) by dependabot[bot] · 3 weeks ago
  83. 59daac6 [fix][broker] Fix broken topic policy implementation compatibility with old pulsar version (#22535) by Rajan Dhabalia · 3 weeks ago
  84. fbf4cb7 [improve][offload] Apply autoSkipNonRecoverableData configuration to tiered storage (#22531) by Baodi Shi · 3 weeks ago
  85. 2badcf6 [fix][broker] Fix NPE causing dispatching to stop when using Key_Shared mode and allowOutOfOrderDelivery=true (#22533) by fengyubiao · 3 weeks ago
  86. 7aedb6b [fix][broker] Fix typos in Consumer class (#22532) by hanmz · 3 weeks ago
  87. 7acbc4c [improve] Run Trivy image scanner with the current image (#22386) by Matteo Merli · 3 weeks ago
  88. 990b8d0 [improve][build] Upgrade OWASP Dependency check version to 9.1.0 (#22530) by Lari Hotari · 3 weeks ago
  89. 72474d7 [fix][broker] Fix a deadlock in SystemTopicBasedTopicPoliciesService during NamespaceEventsSystemTopicFactory init (#22528) by Heesung Sohn · 3 weeks ago
  90. d0b9d471 [fix][broker] Check the broker is available for the SLA monitor bundle when the ExtensibleLoadManager is enabled (#22485) by Kai Wang · 3 weeks ago
  91. 56970b7 [improve][test] Move ShadowManagedLedgerImplTest to flaky tests (#22526) by Lari Hotari · 3 weeks ago
  92. 8ca01cd [improve][admin] Align the auth and check it at the first place for topic related API (#22507) by Jiwei Guo · 3 weeks ago
  93. 94f6c7c [improve][broker] Optimize gzip compression for /metrics endpoint by sharing/caching compressed result (#22521) by Lari Hotari · 3 weeks ago
  94. 1dd82a0 [improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore (#22519) by hanmz · 3 weeks ago
  95. d5b36da [improve][broker] Add topic name to emitted error messages. (#22506) by 道君 · 3 weeks ago
  96. 4ca4e28 [improve] Make the config `metricsBufferResponse` description more effective (#22490) by 道君 · 3 weeks ago
  97. ffdfc0c [fix][test] SchemaMap in AutoConsumeSchema has been reused (#22500) by sinan liu · 3 weeks ago
  98. 70b401b [improve][fn] Expose `RuntimeFlags` as CLI option for Pulsar Functions and Connectors (#22514) by Rui Fu · 3 weeks ago
  99. 203f305 [fix][broker] Fix Replicated Topic unload bug when ExtensibleLoadManager is enabled (#22496) by Heesung Sohn · 3 weeks ago
  100. bbff29d [fix][io] Kafka Source connector maybe stuck (#22511) by Baodi Shi · 3 weeks ago