zachxu42

ErrNoProgress due to parsing/concurrency issue?

5

**Describe the bug** We're using the library across hundreds of instances reading from a Kafka cluster. And the rate of this ErrNoProgress errors is alarmingly high, at around 10/s across...

check remaining bytes when marking batch as empty

4

Fixes [issue-1188](https://github.com/segmentio/kafka-go/issues/1188) and drastically reduce the number of reader errors and dials. Across a couple hundred reader instances, we saw the number of reader errors drop from a couple hundred...

do not initialize message slice in writer with max capacity

3

The benefit of initializing the slice with max batch size as the capacity is minimum compared to the downside - in applications that uses large max batch size but writes...