confluent-kafka-go icon indicating copy to clipboard operation
confluent-kafka-go copied to clipboard

Consumer Resume/Pause Propagating Errors

Open anna-fry opened this issue 2 years ago • 1 comments

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?

anna-fry avatar Jun 29 '22 15:06 anna-fry

It doesn't look like it. Fixing this will be a breaking API change I think. That's awkward.

mhowlett avatar Aug 18 '22 00:08 mhowlett