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

KeyBasedBatchBuilder always timeout #508

Closed
jonyhy96 opened this issue Apr 12, 2021 · 0 comments · Fixed by #509
Closed

KeyBasedBatchBuilder always timeout #508

jonyhy96 opened this issue Apr 12, 2021 · 0 comments · Fixed by #509

Comments

@jonyhy96
Copy link
Contributor

Expected behavior

internalFlushCurrentBatches behave normally like internalFlushCurrentBatch

Actual behavior

internalFlushCurrentBatches always timeout

Steps to reproduce

Use KeyBasedBatchBuilder to produce message and wait for a while, timeout will happens in failTimeoutMessages because of less of sentAt set at here. Should add sentAt like this

System configuration

Pulsar version: any
@sijie sijie mentioned this issue Apr 12, 2021
Closed
@jonyhy96 jonyhy96 mentioned this issue Apr 12, 2021
Merged
wolfstudy pushed a commit that referenced this issue Apr 15, 2021
@jonyhy96
fix: add sentAt when put item into pendingQueue (#509)
b4ec53c 
Signed-off-by: jonyhy96 <hy352144278@gmail.com>

Signed-off-by: jonyhy96 hy352144278@gmail.com

Fixes #508
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.

[issue 508] fix: add sentAt when put item into pendingQueue jonyhy96/pulsar-client-go
1 participant
@jonyhy96