hanwu

Hi, I met the same problem. Have you solved that?

I encountered similar error while using confluent-kafka-python. I inject network fault in my test, with a packet loss over 10% and when the error 'BufferError: Local: Queue full' prompts, most...

Thanks for the advice. Yes I did with the poll() method in the producer. The code is simplified as follows: ``` for i in range(totalMsgNumber): msg = str('some message contents...')...