Duplicate message created using partitioned topic with flink

[prasathsekar]

Search before asking

• [X] I searched in the issues and found nothing similar.

Read release policy

• [X] I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

Version

3.2.3

Minimal reproduce step

Created a partitioned topic in Apache Pulsar and using Flink to consume it. Flink job has a parallelism of 10. If the JOB is restarted getting duplicate(same) messages

What did you expect to see?

Need only the unique message

What did you see instead?

While JOB restart getting same message 5-10 times

Anything else?

No response

Are you willing to submit a PR?

• [X] I'm willing to submit a PR!