Skip to content

Conversation

@accelerated
Copy link
Contributor

Small change in case Consumer destructor throws. If the user has an error callback registered, invoke it instead of the log callback since we know the rdkafka error enum, otherwise fall back unto the log callback. close() throws a HandleException so we catch that instead.

@mfontanini mfontanini merged commit c5aca98 into mfontanini:master Jun 20, 2018
@mfontanini
Copy link
Owner

Thanks!

@accelerated accelerated deleted the consumer_close_error_exception branch November 12, 2018 14:49
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants