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
{{ message }}
This repository has been archived by the owner on Jul 15, 2023. It is now read-only.
dears
I have tried this library , it works very well except one small problem.
The lag can not be committed to zero.For example,if there is 20 messages in the partition, when i call the commit method, the offset in that partition is always 19, there is still one message can not be committed and the lag is 1.
I have tried to attempted the problem as best as my can, but it do not work,so i need your help.
Thanks very much!
The text was updated successfully, but these errors were encountered:
@ducas thank you for your reply .My English is poor,so I'm afraid I don't have a clear expression, thank you again.
I have checked the #27 , I think it is the same problem , I have tried the latest library , but it does not works when using kafka 0.8.2.2 ,so it is with 0.9.0.1.
I have also tried The #47 , but it the lag is still 1 . Something is more interesting is that when I using kafka 0.9.0.1, I can not produce or consume any messages from kafka with this library.
Looking forward to your reply,thank you very much!
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
dears
I have tried this library , it works very well except one small problem.
The lag can not be committed to zero.For example,if there is 20 messages in the partition, when i call the commit method, the offset in that partition is always 19, there is still one message can not be committed and the lag is 1.
I have tried to attempted the problem as best as my can, but it do not work,so i need your help.
Thanks very much!
The text was updated successfully, but these errors were encountered: