search

microsoft / CSharpClient-for-Kafka

.Net implementation of the Apache Kafka Protocol that provides basic functionality through Producer/Consumer classes. The project also offers balanced consumer implementation.
Other
463 stars 95 forks source link

The lag can not be committed to zero #69

Open MoneySuccess opened 8 years ago

MoneySuccess commented 8 years ago

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!

ducas commented 8 years ago

Duplicate of #27

MoneySuccess commented 8 years ago

@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!