confluent-kafka-go
confluent-kafka-go copied to clipboard
Consumer Resume/Pause Propagating Errors
Description
Reading the documentation for the resume and pause functions for consumers in librdkafka here, it seems as though the resume and pause functions that this library wraps always returns a NO_ERROR
and instead adds the error from resuming/pausing the consumer to the partitions list passed to the function. However it does not seem as though the implementation of the pause/resume function looks for the errors within the partitions list when considering whether or not to return an error. Is this a correct understanding of the library's implementation? Is there a way to propagate the error added to the partition list in librdkafka to users of this library?
It doesn't look like it. Fixing this will be a breaking API change I think. That's awkward.