Rob Hansen
Rob Hansen
Hi @mhmtszr, See https://pkg.go.dev/github.com/segmentio/kafka-go?utm_source=godoc#WriteErrors for an example of inspecting individual errors within a WriteErrors. Hopefully that helps! Thanks!
What did you have in mind?
I think that sounds good @mhmtszr, would you be able to submit a pull request?
Hi @natenho, Our docs are definitely lacking around the retry logic which is [here](https://github.com/segmentio/kafka-go/blob/main/writer.go#L1076). Would you be interesting is contributing some documentation updates?
Hi @jonwhitty It sounds like from the docs https://kafka.apache.org/documentation/#brokerconfigs_message.max.bytes that `message.max.bytes` operates against the batch of messages not the individual messages within a batch, so if the batch size is...
Setting the writer Field `BatchBytes` to the value of `message.max.bytes` might be what you're looking for. With that set you should still be able to benefit from batching for smaller...
I may not be understanding what you're looking for could you elaborate a bit on the behavior you're wanting?
I think in that case you're correct, if you'd only like to receive `WriteErrors` you'd need to set a batch size of 1.
Hi @petedannemann thanks for your interesting in contributing! Feel free to get started on this!
Hi @mtkopone, Thanks for the detailed report! Unfortunately based on https://github.com/segmentio/kafka-go/pull/948 I don't we're compatible with 2.8.1 so that could be the problem You could give https://github.com/rhansen2/kafka-go/tree/consumer-group-client , it makes...