Yunze Xu

Could you confirm whether the Python client has been released since you're the release manager of 2.10.1? @codelipenghui BTW, the command should be `pip3 install 'pulsar-client[all]==2.10.1'` on macOS.

Just a suggestion. You can ran the unit tests locally before pushing more commits.

Add the related `release/xxx` labels because it seems there is a deadlock bug of `PartitionedConsumerImpl`, which is removed in this PR. But this bug only happens with branch-2.10, so I...

This PR accidentally fixed a bug that could be reproduced in branch-2.10 so I added other release labels and will cherry-pick it soon. It's better to include this PR in...

The correct process on the following code might be a little complicated. I think we can add a TODO here. ```c++ if (state_ != Ready && state_ != Pending) {...

Just left one final minor comment, LGTM.

It looks like you're using an outdated snappy. Tips, the default snappy on CentOS 7 is too old. You should install a newer snappy as the dependency.

@junquero There're basic e2e tests for Kafka 1.0~2.6, see https://github.com/streamnative/kop/blob/252074234e9044eb9ee166e2a870f12d9712c12d/tests/src/test/java/io/streamnative/pulsar/handlers/kop/KafkaIntegrationTest.java#L91-L100 We may change the test method for different Kafka client versions. Currently it uses docker images to test, I think...

BTW, I'm not familiar with Spring Boot :( It's better to reproduce your problem just using a Kafka client.

@junquero Sorry for the late response. It seems that you've just edited your comment instead of adding a new comment or opening a new issue so that I cannot receive...