New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Received ack for ledgerId:304866784 entryId:71847 on sequenceId 2216277 - expected: 2217115, closing connection #271

Open

Aries-hash opened this issue Sep 5, 2023 · 1 comment

Aries-hash commented Sep 5, 2023

error log :
warning msg="Received ack for ledgerId:304866784 entryId:71847 on sequenceId 2216277 - expected: 2217115, closing connection" producerID=7 producer_na
me=xxx topic="persistent://xxxxxxxx/million_group_push/million_group_push-partition-5"

client version:pulsar-client-go 0.9
broker versiom: 2.9

code:

pulsar-client-go/pulsar/producer_partition.go

Line 1184 in 7f91b2b

response.GetSequenceId(), pi.sequenceID)

It's currently suspected that the else if branch didn't close the connection, triggering this issue. Please assist with optimizing it.

Author

Aries-hash commented Sep 5, 2023

I also reviewed the logic of the sequenceId. The second branch is fine, so it was ignored in the code. The first branch is unacceptable.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment