Reference comment: https://github.com/streamnative/pulsar-rs/pull/371#discussion_r2492455666 Be consistent with the [Java client](https://github.com/apache/pulsar/blob/8c50a6c2e91c81dbf187ce5e66cb39e2758a741e/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java#L42).
