xiaolong ran

> > The point is wrong, can MessageRouter not meet our functions? > > e.g: > > ``` > > producer, err := client.CreateProducer(ProducerOptions{ > > Topic: "my-partitioned-topic", > >...

In here, when we create reader, we need to set the sub partition topic. for example: ``` reader, err := client.CreateReader(pulsar.ReaderOptions{ Topic: "persistent://test-tenant/test-ns/test-topic-partition-0", StartMessageID: pulsar.EarliestMessageID(), }) ```

And the java change is here: https://github.com/apache/pulsar/pull/9995

@longtengz This looks more like a Pulsar SQL bug?

@flowchartsman Thanks your work for this, the change LGTM +1, and can you merge master code and fix test case? Please make sure the CI is ok.

Hello @freeznet The current Master branch has some block code logic that needs to be processed, please do not initiate the release process first

> @wolfstudy could you please help to link the issue? thanks. https://github.com/apache/pulsar-client-go/pull/777 Here, we introduce the function of AckResponse, but the modification of this function blocks the original unit test,...

> @shileiyu It's a good idea. If `RetryEnable==true` in the Java SDK, a default policy is created. In Go SDK, we have also made the same settings. When retry is...

> @wolfstudy Hi! Sorry for direct mention, but could we proceed with this issue in any way? Thanks @omnilight work for this, agree with you.

Thanks @EAHITechnology work for this. **I am a little confused here, why do we need to use the time wheel to handle nack tasks?**