This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5fe096d [pulsar-kafka] support block-producer on queue-full with
sendTimeOut configuration (#6139)
add d3f6c55 [Issue 6173][compaction] Fix log compaction for flow
control/empty topic/last deletion (#6237)
No new revisions were added by this update.
Summary of changes:
.../org/apache/pulsar/client/api/RawReader.java | 7 +++
.../apache/pulsar/client/impl/RawReaderImpl.java | 18 +++++-
.../pulsar/compaction/TwoPhaseCompactor.java | 69 +++++++++++++---------
.../apache/pulsar/client/impl/RawReaderTest.java | 36 ++++++++++-
.../apache/pulsar/compaction/CompactionTest.java | 18 ++++--
.../apache/pulsar/compaction/CompactorTest.java | 2 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 2 +-
7 files changed, 115 insertions(+), 37 deletions(-)
