Hi,
here is example when I try to produce message to non-existent broker at localhost:
examples/rdkafka_example -P -b localhost:9092 -t test00
% Type stuff and hit enter to send
1389364025.904 RDKAFKA-3-FAIL: rdkafka#producer-0: localhost:9092/bootstrap:
localhost:9092/bootstrap: Failed to connect to broker at localhost:9092: Connection refused
And that is fine, since I'm not running kafka broker on my localhost. But If I put external host, it doesn't show any error:
examples/rdkafka_example -P -b 2.2.2.2:9092 -t test00
% Type stuff and hit enter to send
% Sent 1 bytes to topic test00 partition -1
In this case, I'm expecting some "Failed to connect" message or so.
So, how to check does library can make a connection and produce messages?
Regards
Hi,
here is example when I try to produce message to non-existent broker at localhost:
And that is fine, since I'm not running kafka broker on my localhost. But If I put external host, it doesn't show any error:
In this case, I'm expecting some "Failed to connect" message or so.
So, how to check does library can make a connection and produce messages?
Regards