Question: How to detect (un)successful connection to a Kafka broker? about cppkafka HOT 3 OPEN

Can you expand on how it asynchronously throws? I tried using a bogus broker endpoint and it kept running forever trying to reconnect and never crashed. Can you show exactly what you're doing?

Using zookeeper is deprecated IIRC. On newer kafka versions the preferred way is having at least one broker endpoint and if there are more, the rest will be automatically discovered.

from cppkafka.

If I understand you correctly, then when you call producer.flush() the exception throws.
I have this happen when the server is down, etc. I'm wrapping producer.flush() in block try { producer.flush(); } cach (...) {}.

And I set up callback:

• set_delivery_report_callback([&](cppkafka::Producer &, const cppkafka::Message & message) {...})
• set_error_callback([&](cppkafka::KafkaHandleBase &, int error, const std::string & reason){...})

In the first case, I look at the errors, not including 0 (success delivery) and -191 (for more information on errors, see message.h and rdkafka.h) - message.get_error().

In the second case, it is intuitively clear :).

Unfortunately, how to determine that the connection is successful without using the first callback I do not know. The very issue of concern.

from cppkafka.

Sorry it took me ages to reply. I think this question is more suitable to be done on the librdkafka repo as it seems to be implementation specific.

from cppkafka.