Skip to content
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

Ack/Nack use closed consumer #850

Open
billowqiu opened this issue Sep 21, 2022 · 3 comments · May be fixed by #852
Open

Ack/Nack use closed consumer #850

billowqiu opened this issue Sep 21, 2022 · 3 comments · May be fixed by #852

Comments

@billowqiu
Copy link
Contributor

Expected behavior

1：use Client to Subscribe a topic create an consumer-1
2：Receive message use consumer-1
3：then in some case consumer-1 is Closed.
4：use the same Client to create another consumer-2 to Ack/Nack the message

expect consumer-2 to Ack/Nack the message

Actual behavior

the Ack/Nack will use consumer-1 which is Closed before.

image

image

Tell us what happens instead

Steps to reproduce

1：use Client to Subscribe a topic create an consumer-1
2：Receive message use consumer-1
3：then in some case consumer-1 is Closed.
4：use the same Client to create another consumer-2 to Ack/Nack the message

System configuration

Pulsar version: x.y
@billowqiu
Copy link
Contributor Author

I will give an pr to fix this issue.

billowqiu added a commit to billowqiu/pulsar-client-go that referenced this issue Sep 21, 2022
@billowqiu
1: fix apache#850
436c3d0 
2: add some log for pc
@billowqiu billowqiu linked a pull request Sep 21, 2022 that will close this issue
Open
1 task
@billowqiu billowqiu mentioned this issue Oct 9, 2022
Merged
jayxhj added a commit to billowqiu/pulsar-client-go that referenced this issue Oct 18, 2022
@jayxhj
Merge pull request #24 from billowqiu/fix_use_closed_consumer
4410940 
fix apache#850
@codelipenghui
Copy link
Contributor

@billowqiu Do you want to contribute the fix back to apache/pulsar-client-go?

@billowqiu
Copy link
Contributor Author

@billowqiu Do you want to contribute the fix back to apache/pulsar-client-go?

I have submitted a pr in this link: #852

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

Fix ack/nack use closed consumer billowqiu/pulsar-client-go
2 participants
@billowqiu @codelipenghui