(pulsar) branch lh-improve-inline-read-completion updated (9da1761600d5 -> dfc6bf1e9be5)

[lh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a change to branch lh-improve-inline-read-completion
in repository https://gitbox.apache.org/repos/asf/pulsar.git


    from 9da1761600d5 [test][ml] Enable inline read completion in default test config
     add c70a40cbcdd7 [fix][client] Keep a gone segment's producer until the layout drops it (#26617)
     add 467159eb8807 [fix][ml] Fix active cursor position tracking after untracking (#26629)
     add df943ebee5d2 [fix][test] Fix flaky ManagedLedgerBkTest.verifyConcurrentUsage (#26637)
     add 3efae196f462 [improve][ml] Defer cached message metadata parsing until first read (#26628)
     add 95d170e0591c [fix][broker] Prevent slow Key_Shared sockets from stalling other consumers (#26635)
     add de49904f1fd6 [improve][client] Pull v5 blocking receives straight from the receive buffer (#26614)
     add 4387c6fad904 [improve][client] Skip redundant per-segment cumulative acks in the v5 stream consumer (#26616)
     add ea97c3c7e50b [fix][ci] Skip pull request title check outside apache/pulsar (#26645)
     add dfc6bf1e9be5 Merge origin/master into lh-improve-inline-read-completion

No new revisions were added by this update.

Summary of changes:
 .github/workflows/ci-semantic-pull-request.yml     |   1 +
 .../impl/ActiveManagedCursorContainerImpl.java     |  14 +-
 .../apache/bookkeeper/mledger/impl/EntryImpl.java  |   9 +-
 .../mledger/impl/cache/RangeEntryCacheImpl.java    |  16 +-
 ...ActiveManagedCursorContainerUntrackingTest.java | 163 +++++++++++++
 .../bookkeeper/mledger/impl/EntryImplTest.java     |  22 ++
 .../mledger/impl/ManagedLedgerBkTest.java          |  51 ++++-
 .../impl/cache/RangeEntryCacheImplTest.java        | 112 +++++++--
 .../impl/cache/EntryCacheMetadataBenchmark.java    | 119 ++++++++++
 .../impl/cache/RangeCacheReadBenchmark.java        |   2 +-
 ...istentStickyKeyDispatcherMultipleConsumers.java |   8 +-
 .../persistent/KeySharedSlowConsumerTest.java      | 129 +++++++++++
 ...ntStickyKeyDispatcherMultipleConsumersTest.java |  44 ++++
 .../pulsar/client/api/v5/V5CumulativeAckTest.java  | 121 ++++++++++
 .../client/impl/v5/V5ProducerSegmentGoneTest.java  | 205 +++++++++++++++++
 .../impl/v5/V5StreamConsumerAckWatermarkTest.java  | 130 +++++++++++
 .../client/impl/v5/ScalableStreamConsumer.java     |  93 +++++++-
 .../client/impl/v5/ScalableTopicProducer.java      |  57 +++--
 .../pulsar/client/impl/v5/V5ReceiveQueue.java      | 251 ++++++++++++++-------
 .../pulsar/client/impl/v5/V5ReceiveQueueTest.java  | 197 ++++++++++++++++
 20 files changed, 1605 insertions(+), 139 deletions(-)
 create mode 100644 managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ActiveManagedCursorContainerUntrackingTest.java
 create mode 100644 microbench/src/main/java/org/apache/bookkeeper/mledger/impl/cache/EntryCacheMetadataBenchmark.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/KeySharedSlowConsumerTest.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/client/impl/v5/V5ProducerSegmentGoneTest.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/client/impl/v5/V5StreamConsumerAckWatermarkTest.java