Kai Wang

关于DW1830休眠后ping延迟变高等问题

2

最近几天使用macos时发现一些问题 希望有大神能看看 谢谢！ 1.连接电源休眠后wifiping延迟会变高而且还会丢包 （平时1/~10ms 休眠后100/~1000ms) 2.有时无法连接wifi 提示如下（但是我把电源线拔掉后瞬间连接wifi并且延迟变低）  3.在tmp目录下发现很多wifi 日志  下面是系统日志、部分wifi日志和部分EFI里的文件： [日志和EFI.zip](https://github.com/darkhandz/XPS15-9550-Sierra/files/1167975/EFI.zip) 系统版本：10.12.6 配置：与@darkhandz一样 @darkhandz @sysc @soulomoon

[improve][doc] Add specified_positions_divide split algorithm in doc

4

### Motivation #13796 added specified_positions_divide split algorithm, but some docs are missing. ### Documentation Check the box below or label this PR directly. Need to update docs? - [ ]...

[improve] Trigger pending fetches when producing messages

2

Fixes #1419 ### Motivation When the Kafka client issues a Fetch and sets a max wait time we are already scheduling a DelayedFetch, but there is no way to trigger...

Flaky-test: KafkaMessageOrderKafkaTest.testKafkaProduceMessageOrder

1

KafkaMessageOrderKafkaTest is flaky. The testKafkaProduceMessageOrder test method fails sporadically. [example failure](https://github.com/streamnative/kop/runs/7738563391?check_suite_focus=true#step:12:207) ``` Error: testKafkaProduceMessageOrder(io.streamnative.pulsar.handlers.kop.KafkaMessageOrderKafkaTest) Time elapsed: 0.194 s

When the Kafka client issues a Fetch and sets a maxWait time we are already scheduling a DelayedFetch, but there is no way to trigger that Fetch and it is...

TODO: We still need to test to find out the best `explicitFlushAfterFlushes` config value. The better option is migration the [`org.apache.cassandra.transport.Flusher`](https://github.com/apache/cassandra/blob/trunk/src/java/org/apache/cassandra/transport/Flusher.java). It can reduce the flush count and reduce the...

Flaky-test: UpgradeTest.testConsumeLatest

1

UpgradeTest is flaky. The testConsumeLatest test method fails sporadically. [example failure](https://github.com/streamnative/kop/runs/5858286648?check_suite_focus=true#step:5:254) ``` Error: testConsumeLatest(io.streamnative.pulsar.handlers.kop.UpgradeTest) Time elapsed: 4.365 s

### Task list - [x] Support producer state manager(#912 ) - [ ] Support producer state manager snapshot and recover(#960 ) - [ ] Support producer ID expiration