partitionProducer Send stuck #877
Comments
1 task
1 task
RobertIndie
pushed a commit
that referenced
this issue
Jul 11, 2023
…ng as expected (#1053) Fixes #877 ### Motivation The original PR is #878. Because the original author @billowqiu has not continued to reply to the review comments for a long time, resubmit the fix here. ### Modifications - Add select for ctx and doneCh in partitionProducer.Send() --------- Co-authored-by: shenjiaqi.2769 <[email protected]>
RobertIndie
pushed a commit
that referenced
this issue
Sep 7, 2023
…ng as expected (#1053) Fixes #877 ### Motivation The original PR is #878. Because the original author @billowqiu has not continued to reply to the review comments for a long time, resubmit the fix here. ### Modifications - Add select for ctx and doneCh in partitionProducer.Send() --------- Co-authored-by: shenjiaqi.2769 <[email protected]> (cherry picked from commit be35740)
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
We use fork version in this line：https://github.com/billowqiu/pulsar-client-go/blob/1dc06ae37025b011ecc345312a65d797b436dedb/pulsar/producer_partition.go#L745
but the upstream version have the same problem.
Expected behavior
partitionProducer.Send should return after success or timeout.
Actual behavior
stuck in doneCh.
Steps to reproduce
How can we reproduce the issue
System configuration
Pulsar version: x.y
The text was updated successfully, but these errors were encountered: