kafka-go
kafka-go copied to clipboard
Provide contextual information when producing errShortRead
Describe the solution you'd like
The use of errShortRead
in the kafka-go code should be wrapped with fmt.Errorf
to provide contextual information about why we hit that error. We would test with errors.Is
instead of ==
or !=
.
This will help track down https://github.com/segmentio/kafka-go/issues/621