You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Dec 14, 2022. It is now read-only.
If you use an existing subscription and start using the subscription mode of the connector, the first message will be lost.
To Reproduce
Steps to reproduce the behavior:
Create a subscriber for the topic, write 1-100 messages to the topic,
Let Consumer of pulsar-client use this subscriber's message.
Write 1-100 messages to the topic again.
Use the Pulsar-flink connector subscription mode to start, and the first consumed message is lost.
Expected behavior
With existing subscribers, the first message will not be lost.
Screenshots
If applicable, add screenshots to help explain your problem.
Additional context
When the connector submits the cursor to pulsar, the submitted cursor is the last message currently consumed. Pulsar admin defaults that the current message is the first message of the next consumption.
In the connector, the first message is lost by default, which is also the reason for the problem. The root cause is that the cursor submitted by the connector does not comply with pulsar's rules, resulting in inconsistent behavior.
The text was updated successfully, but these errors were encountered:
When this problem is solved, there will be one less cursor submitted by pulsar-flink than expected. The subscription mode will consume one more message when using the connector that fixes the problem. Repeated consumption will only happen this time.
Describe the bug
If you use an existing subscription and start using the subscription mode of the connector, the first message will be lost.
To Reproduce
Steps to reproduce the behavior:
Expected behavior
With existing subscribers, the first message will not be lost.
Screenshots
If applicable, add screenshots to help explain your problem.
Additional context
When the connector submits the cursor to pulsar, the submitted cursor is the last message currently consumed. Pulsar admin defaults that the current message is the first message of the next consumption.
In the connector, the first message is lost by default, which is also the reason for the problem.
The root cause is that the cursor submitted by the connector does not comply with pulsar's rules, resulting in inconsistent behavior.
The text was updated successfully, but these errors were encountered: