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
-
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