fix(kafka_issues581): fix over capacity deadlock · AutoMQ/automq-for-rocketmq@2dc6a84

Process completed with exit code 1.

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/NormalMessageSizeTest.java#L366

Send message failed after 3 retries, expected success, message: The producer service state not OK, START_FAILED See http://rocketmq.apache.org/docs/faq/ for further details.

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/NormalMessageSizeTest.java#L246

Send message failed, expected success, message:send message Exception For more information, please visit the url, http://rocketmq.apache.org/docs/faq/

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/NormalMessageSizeTest.java#L315

org.apache.rocketmq.remoting.exception.RemotingTimeoutException: wait response on the channel <10.128.4.225:8081> timeout, 2998(ms)

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/TagFilterTest.java#L105

send message failed ==> expected: <20> but was: <19>

rocketmq-e2e/java/e2e-v4/src/test/java/org/apache/rocketmq/offset/OffsetTest.java#L95

receive response count not match

rocketmq-e2e/java/e2e-v4/src/test/java/org/apache/rocketmq/offset/OffsetTest.java#L225

receive response count not match

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/TagFilterTest.java#L224

send message failed ==> expected: <20> but was: <18>

rocketmq-e2e/java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/TagFilterTest.java#L256

send message failed ==> expected: <10> but was: <9>