yapeng
yapeng
### Motivation *consumer client has method pause(), but consumer is not really paused. paused consumer only stop send flow permit request to broker but broker still can push messages to...
prefer to use index in BrokerEntryMetadata and considering batchIndex when build sequenceId. Fixes #17061 ### Motivation In pulsar function EFFECTIVELY_ONCE semantic, producer attach a sequenceId to output topic for deduplication,...
### Preflight Checklist - [x] I have searched [existing issues](https://github.com/anthropics/claude-code/issues?q=is%3Aissue%20state%3Aopen%20label%3Abug) and this hasn't been reported yet - [x] This is a single bug report (please file separate reports for different...