keyboardbobo

We have 4 pulsar brokers and 4 bookie, the broker traffic is about 400M, the bookie traffic is about 1G, and the traffic is relatively large. During the day of...

fix: ListOffset interface returns an incorrect result

2

The commit offset and partition data expire at the same time, and the ListOffset interface returns an incorrect result *(If this PR fixes a github issue, please add `Fixes #`.)*...

[BUG]The commit offset and partition data expire at the same time, and the ListOffset interface returns an incorrect result

1

**Describe the bug** The client requests the commit offset of all partitions according to offsetFetch. If the commit offset of the partition expires, the broker returns the offset of the...

BookieNettyServer#listenOn netty WRITE_BUFFER_WATER_MARK setting does not take effect

2

**BUG REPORT** ***Describe the bug*** ``` bootstrap.option(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark( conf.getServerWriteBufferLowWaterMark(), conf.getServerWriteBufferHighWaterMark())); ``` should be : ``` bootstrap.childOption(ChannelOption.WRITE_BUFFER_WATER_MARK, new WriteBufferWaterMark( conf.getServerWriteBufferLowWaterMark(), conf.getServerWriteBufferHighWaterMark())); ``` Instead of setting the parameters of option, set...

ConcurrentLongHashMap may throw an ArrayIndexOutOfBoundsException

1

@lhotari @thetumbled please take a look at this issue. **BUG REPORT** Due to previous issues with `EBADREQ` (bookie error : `Unexpected exception while writing` ), I cherry-pick the PR: `https://github.com/apache/bookkeeper/pull/4066`,...

**BUG REPORT** ***Describe the bug*** like `org.apache.bookkeeper.proto.PacketProcessorBase#sendResponse`, if the client is unable to process in time, use Netty high water level control to avoid FullGC or OOM ***Expected behavior*** `org.apache.bookkeeper.proto.BookieRequestHandler#flushPendingResponse`...