hangc0276 commented on issue #12759: URL: https://github.com/apache/pulsar/issues/12759#issuecomment-980845899
This is the expected behavior. It was introduced by https://github.com/apache/pulsar/wiki/PIP-33%3A-Replicated-subscriptions In order to support replicated subscription stats between different pulsar clusters, it will start subscription snapshot every 1 second by default if we enable this feature in consumer subscription `replicateSubscriptionState(true)`. The snapshot will write an internal mark into the topic message and will be filter out on message dispatch period. Thus you will see the messageId has been acked even though you haven't ack the message yet. In fact, you will never receive this message. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
