道君

I just don't understand, it seems ReplicatorSubscriptionController only snapshots `ledger.lastPosition`, why do we update `lastDataMessagePublishedTimestamp` after `maxReadPosition` moved?

> > I just don't understand, it seems ReplicatorSubscriptionController only snapshots `ledger.lastPosition`, why do we update `lastDataMessagePublishedTimestamp` after `maxReadPosition` moved? > > We may need to have a discussion about...

 The test keeps failing, could you please resolve it?

Closing and reopening to get recent changes from master branch to the PR build.

@poorbarcode any more change requests?

For the purpose of reduce the sync-api send message latency, client will flush messages to broker when you call the sync-api. And sync-api will block your app's threads, if we...

@lhotari I think support batch message for sync-api has potential risks, as I mentioned before, if we don't flush messages but waiting until the batch is full, it may block...

Origin PR: https://github.com/apache/pulsar/pull/17485

> I think that AsyncTokenBucket should be used for rate limiting instead of implementing a separate solution. It was introduced in PIP-322. @lhotari TimeWindow is not introduced by this PR,...

@lhotari I will move AsyncTokenBucket related class from pulsar-broker to pulsar-common, is it OK?