Can we use consumption limit in kafka-go

[lizhifengones]

like consumer_byte_rate, I didn't find it. : (

[rhansen2]

Hi @lizhifengones,

I'm not familiar with consumer_byte_rate. The only reference to it I can find appears to be a broker side quota setting. https://kafka.apache.org/documentation/#quotas If that's the case then I believe this feature should work with kafka-go.

Please let me know if there's something I'm missing.

Thanks!

[achille-roussel]

Is this question related to #919 ?

[lizhifengones]

Is this question related to #919 ?

Yes, but it seems that batch suffices, it limits the bytes per consumption of kafka.

But unfortunately, the batch seems to have a memory leak caused by goruntine leaks (#922 (comment)) . Each time the batch ends, the memory can only be released a little . I am now excluding the impact of my own code and follow up the test.

[lizhifengones]

I have no problem for now