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.

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

Incorrect Value for BufferedFetchRecords When Pausing/Resuming #865

Open
mehranmeidani opened this issue Nov 27, 2024 · 0 comments
Open

Comments

@mehranmeidani
Copy link

When pausing a partition, and then resume it, the client will consume all messages, but the value of buffered fetches remains > 0.

How to reproduce:

  1. Start a consumer
  2. Pause a partition
  3. Resume a partition

I believe kgo.takeNBuffered does not decrease the number of buffered messages for the paused partition/topic despite the fact that it calls allowUsable on the curosr and skip the message.

I have a sample code that shows a client that consumes all messages eventually, but the BufferedFetchRecords still shows some buffered messages in the client.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant