Kunshuai Zhu

### Description Complete the function of mqtt plugin ### Task List Complete the places marked with todo - [ ] QoS 1 - [ ] QoS 2 - [ ]...

[Volunteer] Improve unit test coverage of shenyu-common

13

### Volunteer help As a branch of #3274 . At present, the test coverage of shenyu-common module is not high. Please try to make the test coverage of each class...

[GSoC 2022] Integration tests cover more scenarios

7

### Description Shenyu already has a relatively complete integration testing framework, but some plug-ins have not been tested, such as oathu2 plugin, cache plugin, metrics plugin, log-rockermq plugin, and etc....

Hi folks, I found a problem when I use it like below. ```java stub = xxx.newReactorStub(channel); stub.manyToMany(Flux.range(1, 10).map(i -> Message.newBuilder().setNumber(i).build()) .doOnNext(System.out::println)); ``` When I did not subscribe, the client terminal...

- [X] I have searched the [issues](https://github.com/apache/dubbo/issues) of this repository and believe that this is not a duplicate. ## Describe the proposal This is a issue in OSPP-2022, see https://summer-ospp.ac.cn/#/org/prodetail/22a7f0101...

About https://github.com/apache/dubbo/issues/10288 & https://github.com/apache/dubbo/pull/10290

Add integration test for unary call with StreamObserver ping @EarthChen

About https://github.com/apache/dubbo/issues/10288

Things shenyu kubernetes controller may need to do

2

### Volunteer help Currently, we implement the ingress controller in the shenyu-kubernetes-controller module. It takes the form of spring-starter and is embedded in the gateway data plane. We still have...