Consumer client and rd_kafka_conf_set_error_cb #4585
Unanswered
andreamartini
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
I'm using c++ librdkafka 2.3.0.
I created a simple client consumer for kafka. I would like to test if my client consumer is able to intercept error like network connection lost and so on.
To do that, i use two callbacks in this way:
After i disconnect network cable(to cause network error), client invokes method CKafkaTestConsumer::_loggerCallback, but no CKafkaTestConsumer::_errorCallback.
Unfortunally in CKafkaTestConsumer::_loggerCallback i have no error detection. I have to parse const char* buf to understand error type.
My questions are:
thank you in advance.
Kind regards
Beta Was this translation helpful? Give feedback.
All reactions