zachxu42

Thanks @petedannemann for the comment. We have frequent small writes but also occasional large writes. Ideally the batch size and batch bytes can be adjusted dynamically based on the write...

Thanks @petedannemann for the comment. I believe #1177 is a different case, when the error is **not** nil. In this PR I could change it to do the same ```...

Spent a day poking around, and found the most promising theory to be the following * A goroutine couldn't finish reading all the bytes meant for it; Leaving unfinished bytes...

cc`ing @rhansen2. Sorry I know it's been more than 2 years.. But wanted to keep you in the loop since you're the author of [#788](https://github.com/segmentio/kafka-go/pull/788). Do you by any chance...

Thanks @aratz-lasa for the comment. Can you please elaborate this part? > HighWatermark is the last offset that is available, not the last+1. Also I never fully understand the reason...