[Bug] [txn] Consumer can receive txn aborted message when readType is replay

[TakaHiR07]

Search before asking

• I searched in the issues and found nothing similar.

Version

server version: branch-2.9
client version: branch-2.9

Minimal reproduce step

1. txn produce large number of message, enabling batch. Transactions include commit and abort.
2. use shared consumer to do normal consume.
3. During the consume process, restart consumer several times.
4. See that consumer has consumed part of aborted messages.

What did you expect to see?

when enable transaction, consumer should not receive aborted message

What did you see instead?

consumer can receive aborted message , in the situation of shared subscription + batch message + consumer restart.

Anything else?

Testing in pulsar-2.9, but I think master branch also have this problem.

Are you willing to submit a PR?

• I'm willing to submit a PR!

[github-actions]

The issue had no activity for 30 days, mark with Stale label.