You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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:
Start a consumer
Pause a partition
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.
The text was updated successfully, but these errors were encountered:
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:
I believe
kgo.takeNBuffered
does not decrease the number of buffered messages for the paused partition/topic despite the fact that it callsallowUsable
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.The text was updated successfully, but these errors were encountered: