Google Git
Sign in
apache/pulsar/HEAD
  1. 7a9fefb [fix][broker] Fix compacted read could be stuck forever or message loss due to cursor mark delete (#25998) by Yunze Xu · 6 hours ago master
  2. 20dc8f9 [improve][broker] PIP-483: scalable topic auto split/merge (#25980) by Matteo Merli · 7 hours ago
  3. e21c471 [fix][build] Fix generateOpenApiSpecs task and include missing admin v2 resources in the spec (#26003) by Lari Hotari · 10 hours ago
  4. 1ab1331 [improve][broker] PIP-483: Scalable Topic Auto Split/Merge (#25938) by Matteo Merli · 17 hours ago
  5. 140e139 [improve][build] Upgrade async-http-client to 3.0.10 (#25023) by Matteo Merli · 19 hours ago
  6. 565b59b [improve][ml] Propagate slog logger context to BookKeeper ledger create/open (#25995) by Matteo Merli · 19 hours ago
  7. a045e4c [feat][fn] Add message decoding failure handling (#25972) by Rui Fu · 25 hours ago
  8. 982eac3 [feat] Upgrade BookKeeper dependency to 4.18.0 (#25886) by Hang Chen · 34 hours ago
  9. fe50567 [improve][broker] Improve default limits for acknowledgment state persistence and Key_Shared look-ahead (#25992) by Lari Hotari · 36 hours ago
  10. 5699d04 [fix][meta] PIP-454: fix stale migration status reported after completion (#25993) by Matteo Merli · 2 days ago
  11. 67ec614 [fix][meta] PIP-454: fix migration retry after failure, preparation timeout and mid-migration store startup (#25989) by Matteo Merli · 2 days ago
  12. 98bac65 [fix][ml] Reset messageMetadataInitialized when recycling RangeCacheEntryWrapper (#25987) by Matteo Merli · 2 days ago
  13. 7148b19 [fix][broker] Avoid per-message metadata parse for disabled debug log in handleSend (#25986) by Matteo Merli · 2 days ago
  14. fbcfacf [fix][ml] Fix eviction trigger race that cleared the in-progress marker (#25988) by Matteo Merli · 2 days ago
  15. 94de2b6 [improve][txn] PIP-473: GC aborted-transaction records on ML trim and segment drop (#25975) by Matteo Merli · 3 days ago
  16. 36270cc [improve][test] pulsar-perf consume: switch between V5 Queue and Stream consumer (#25981) by Matteo Merli · 3 days ago
  17. 083fd4c [improve][broker] Default managedLedgerMaxReadsInFlightSizeInMB to 15% of direct memory (#25979) by Lari Hotari · 3 days ago
  18. 1eb08ed [fix][test] Deflake TopicPoliciesTest.setupTestTopic by retrying forced namespace deletion (#25974) by Lari Hotari · 4 days ago
  19. 65b4321 [fix][test] Fix flaky ExtensibleLoadManagerImplTest.initializeState by recovering wedged channel ownership (#25977) by Lari Hotari · 4 days ago
  20. b50a303 [fix][test] Fix flaky ExtensibleLoadManagerImplTest by re-serving the channel topic in initializeState (#25976) by Matteo Merli · 4 days ago
  21. 492a231 [improve][misc] Upgrade log4j to 2.26.0 and slf4j to 2.0.18 (#25973) by Lari Hotari · 4 days ago
  22. d17f85c [improve][misc] Upgrade lz4-java to 1.11.0 (#25971) by Lari Hotari · 4 days ago
  23. d711f3d2 [improve][misc] Upgrade Guava to 33.6.0 (#25970) by Lari Hotari · 4 days ago
  24. 301d655 [fix][txn] PIP-473: prune terminal transactions from the metadata buffer cache (#25960) by Matteo Merli · 4 days ago
  25. 0daa5aa [improve][test] PIP-473: extensive v5 transaction tests on scalable topics (#25958) by Matteo Merli · 4 days ago
  26. f0d2bcc [feat][client] Embed GraalVM native image config (#25883) by David Kjerrumgaard · 4 days ago
  27. 7399b1c [improve][misc] Make Protobuf v4 the default (#25969) by Lari Hotari · 4 days ago
  28. bf709ee [fix][ci] Fix CodeQL job which is currently broken (#25966) by Lari Hotari · 4 days ago
  29. f3d7c76 [fix][test] Fix flaky test ReplicatorTest.testResumptionAfterBacklogRelaxed (#25950) by void-ptr974 · 4 days ago
  30. 450e980 [fix][txn] PIP-473: v5 transaction timeout applied 1000x too long (#25959) by Matteo Merli · 4 days ago
  31. 1ec96ad [fix][ci] Prevent Pull Request Labeler from canceling runs across PRs (#25968) by Lari Hotari · 4 days ago
  32. b686e96 [improve][misc] Upgrade Apache Commons libraries and Apache Http components (#25963) by Lari Hotari · 4 days ago
  33. c78f832 [improve][misc] Migrate Yahoo DataSketches to Apache DataSketches (#25965) by Lari Hotari · 4 days ago
  34. ef5e0ff [improve][meta] Upgrade Oxia client to 0.8.0 (#25962) by Qiang Zhao · 4 days ago
  35. ef010c3 [fix][test] PIP-473: deflake TransactionCoordinatorV5Test.sweepTimeouts_abortsExpiredOpenTxnAndFansOut (#25961) by Matteo Merli · 4 days ago
  36. 4bcc4a0 [fix][client] Avoid closing reused ServiceUrlProvider in another PulsarClientImpl instance (#25947) by Oneby Wang · 4 days ago
  37. b75d780 [fix][test] Stabilize flaky sweepTimeouts_abortsExpiredOpenTxnAndFansOut() test (#25952) by Oneby Wang · 4 days ago
  38. 40d3254 [fix][broker] Prevent dedup recovery race from allowing duplicate messages (#25953) by void-ptr974 · 4 days ago
  39. 1019024 [fix][broker] Fix tableview divergence in ServiceUnitStateTableViewSyncer causing flaky tests (#25946) by Lari Hotari · 5 days ago
  40. 2774a9d [fix][test] Stabilize delayed auditor lost bookie tests in AuditorLedgerCheckerTest (#25957) by Oneby Wang · 5 days ago
  41. c670571 [improve][broker] PIP-473 P5.4: v4/v5 transaction coordinator coexistence + enable v5 by default (#25945) by Matteo Merli · 5 days ago
  42. 1414387 [fix][test] Fix flaky SaslAuthenticateTest.testMaxInflightContext() test (#25948) by Oneby Wang · 6 days ago
  43. c3a490b [improve][misc] Upgrade Jetty to 12.1.10 (#25943) by Lari Hotari · 7 days ago
  44. 2177b0e [fix][fn] Fix orphan exclusive producer on creation timeout in WorkerUtils.createExclusiveProducerWithRetry (#25942) by Lari Hotari · 7 days ago
  45. f0a3149 [fix][client] Preserve equals in FieldParser map values (#25907) by 陈家名 · 7 days ago
  46. 26cf550 [improve][client] Clean up unacked message tracker when topics are removed in multi-topic consumers (#25923) by Dream95 · 7 days ago
  47. 4e50957 [fix][client] Match logical topic when removing unacked messages (#25921) by Dream95 · 7 days ago
  48. cec32df [improve][doc] Add coding guideline for fully qualified class names (#25928) by Ruimin MA · 7 days ago
  49. 9624715 [improve][misc] Migrate Swagger annotations to OpenAPI 3 (Swagger Core v3, jakarta) (#25937) by Lari Hotari · 7 days ago
  50. 17ead1d [improve][broker] PIP-473 P5.3: metadata-store TC leader election + assignment watch (#25929) by Matteo Merli · 7 days ago
  51. cf2faef [cleanup][client] Remove unused RetryUtil class (#25934) by Lari Hotari · 8 days ago
  52. ef5e25c [fix][ci] Use CodeQL build-mode: none to avoid intermittent build-cache failures (#25932) by Matteo Merli · 8 days ago
  53. f638a89 [fix][misc] Update docker image guide and version scripts (#25930) by Philipp Dolif · 8 days ago
  54. ab047fd [improve][cli] Support 'auto_consume' schema type in pulsar-client consume/read (#25927) by Matteo Merli · 8 days ago
  55. 67fa1a4 [cleanup][misc] Remove obsolete LoadSimulationClient and LoadSimulationController (#25926) by Matteo Merli · 8 days ago
  56. 1bbe964 [improve][misc] Upgrade vert.x to 4.5.28 (#25924) by Lari Hotari · 8 days ago
  57. 820300f [improve][cli] Migrate pulsar-client to the V5 client API (#25917) by Matteo Merli · 8 days ago
  58. cc9fddc [improve][functions] Allow customizing Kubernetes service domain suffix in Function Worker (#25872) by iantowey · 9 days ago
  59. 7ab0941 [fix][test] Stabilize testSecondaryIsolationGroupsBookiesNegative() test (#25900) by Oneby Wang · 9 days ago
  60. e22fa0b [fix][misc] Throw TypeConversionException when ByteUnitToIntegerConverter's long->int conversion overflows (#25901) by 陈家名 · 9 days ago
  61. 7ecedb8 [improve][offload] Coalesce automatic offload triggers to reduce retry loops and ledger scans (#25793) by void-ptr974 · 9 days ago
  62. 882946c [fix][client] Prevent duplicate ServiceUrlProvider initialization (#25899) by Oneby Wang · 9 days ago
  63. b45aa4e [cleanup][broker] Clean up scalable topic type references in ServerCnx (#25920) by Ruimin MA · 9 days ago
  64. 2acee32 [fix][proxy] Avoid intermittent 502 when admin proxy follows a broker redirect for a request with a body (#25919) by Lari Hotari · 9 days ago
  65. 756c03d [fix][client] Clean up unacked messages when unsubscribing a topic with ack timeout backoff (#25916) by Dream95 · 9 days ago
  66. df953e9 [fix][sec] Upgrade Netty to 4.1.135.Final to address several CVEs (#25918) by Lari Hotari · 9 days ago
  67. d57af8f [improve][fn] make built-in functions reload incremental (#25868) by Pratik Katti · 10 days ago
  68. 5627c01 [fix][meta] Fix ZooKeeper session reconnect race condition in PulsarZooKeeperClient.clientCreator (#25910) by Oneby Wang · 10 days ago
  69. ed09950 [fix][test] Fix flaky SameAuthParamsLookupAutoClusterFailoverTest.testAutoClusterFailover() test (#25892) by Oneby Wang · 10 days ago
  70. be9f97a [fix][meta] Fix PulsarZooKeeperClient async addWatch callback retry behavior (#25913) by Oneby Wang · 10 days ago
  71. 90c81d74 [improve][broker] PIP-473 P5.2: scalable-topics TC timeout + GC sweeps (#25884) by Matteo Merli · 10 days ago
  72. caa493b [improve][test] Migrate pulsar-perf to the V5 client API (#25887) by Matteo Merli · 10 days ago
  73. 6bfa77d [improve][misc] PIP-472: Migrate from javax.* to jakarta.* APIs (#25912) by Lari Hotari · 11 days ago
  74. f2a22bb [improve][build] Upgrade OpenTelemetry to latest (java 1.62.0, instrumentation 2.28.1, semconv 1.41.1) (#25906) by Lari Hotari · 11 days ago
  75. 14e228c [improve][build] Upgrade Athenz to 1.12.42 (#25905) by Lari Hotari · 11 days ago
  76. a6af801 [fix][test] Fix flaky PulsarFunctionTlsTest.testFunctionsCreation() test (#25889) by Oneby Wang · 13 days ago
  77. 1fa9e35 [fix][broker] Fix non-batched null-value messages not removed during topic compaction (#25817) by grishaf · 2 weeks ago
  78. 9f2e461 [fix][client] PIP-475: make async producer survive regular-to-scalable migration (#25882) by Matteo Merli · 2 weeks ago
  79. ef27cd2 [improve][proxy] Support scalable topics through the proxy (#25879) by Matteo Merli · 2 weeks ago
  80. 951a426 [test][broker] PIP-475: end-to-end migration tests + transition fixes (#25878) by Matteo Merli · 2 weeks ago
  81. 5991f6e [improve][broker] PIP-473 P5.1: metadata-driven transaction coordinator (NEW_TXN / END_TXN) (#25863) by Matteo Merli · 2 weeks ago
  82. ddd82db [improve][misc] Add AGENTS.md and split build/contributor/coding/architecture/security docs (#25871) by Lari Hotari · 2 weeks ago
  83. b93fe9e [fix][bk] Fix NPE in IsolatedBookieEnsemblePlacementPolicy when policy class does not match (#25825) by Yike Xiao · 2 weeks ago
  84. 8f9502f [feat][broker] PIP-475: regular-to-scalable topic migration command (#25875) by Matteo Merli · 2 weeks ago
  85. 334ec6e [improve][broker] Simplify listener config and support proxyless Admin API (complete PIP-61/PIP-95) (#25851) by Lari Hotari · 2 weeks ago
  86. a24a3b5 [improve][misc] Upgrade Netty to 4.1.134 (#25870) by Lari Hotari · 2 weeks ago
  87. 47eec87 [fix][broker] Fix PersistentMessageExpiryMonitor findEntryComplete() method may lose mark-delete properties in race condition (#25803) by Oneby Wang · 3 weeks ago
  88. b406518 Return 400 for invalid reader messageId query parameter (#25865) by Pratik Katti · 3 weeks ago
  89. 59d1495 [fix][client] Fix failed to close consumer because of the error: param memorySize is a negative value (#25805) by fengyubiao · 3 weeks ago
  90. 9b15504 [fix][broker] Fix compaction cursor reset may lose mark-delete properties (#25862) by Oneby Wang · 3 weeks ago
  91. 2e02b78 [fix][test] Fix flaky ProducerCleanupTest timer cleanup (#25864) by Oneby Wang · 3 weeks ago
  92. a5c1029 [fix][fn] Fix Go function runtime to continue after user exceptions and add neg-ack tests (#25867) by Dream95 · 3 weeks ago
  93. 3b6a760 [fix][test] Stabilize WebService rate limiting test (#25866) by Oneby Wang · 3 weeks ago
  94. 09035ff [improve][client] In cases where there is a risk of message loss, adjust the log level to error (#25854) by fengyubiao · 3 weeks ago
  95. c26d612 [improve][build] Upgrade kubernetes client-java to 26.0.0 (#25856) by Lari Hotari · 3 weeks ago
  96. 11f7bcd [fix][test] Fix flaky ResendRequestTest.testSharedSingleAckedPartitionedTopic() test (#25852) by Oneby Wang · 3 weeks ago
  97. 842785e [improve][build] Remove kotlin-stdlib override; upgrade okhttp3 5.3.2 and okio 3.17.0 (#25855) by Lari Hotari · 3 weeks ago
  98. 86311b1 [feat][client] PIP-475: V5 SDK consumes synthetic layouts for regular topics (#25850) by Matteo Merli · 3 weeks ago
  99. 7e4de06 [improve][broker] PIP-473 P3.5: durable per-segment visibility state (#25821) by Matteo Merli · 3 weeks ago
  100. 953bf34 [feat][broker] PIP-475: synthetic-layout lookup for regular topics (#25822) by Matteo Merli · 3 weeks ago