Description
I am not getting any exception will creating the producer
- running pytest in a docker container on ubuntu
- the server is down to test bad connectivity
Here is a successful error handling when connecting to 127.0.0.1:9092:
[kafka.producer.kafka] Starting the Kafka producer
[kafka.client] Bootstrapping cluster metadata from [('127.0.0.1', 9092, <AddressFamily.AF_INET: 2>)]
[kafka.client] Attempting to bootstrap via node at 127.0.0.1:9092
[kafka.conn] <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 None]>: creating new socket
[kafka.conn] <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 ('127.0.0.1', 9092)]>: setting socket option (6, 1, 1)
[kafka.conn] <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 ('127.0.0.1', 9092)]>: connecting to 127.0.0.1:9092 [('127.0.0.1', 9092) IPv4]
[kafka.conn] Connect attempt to <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 ('127.0.0.1', 9092)]> returned error 111. Disconnecting.
[kafka.conn] <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 ('127.0.0.1', 9092)]>: Closing connection. KafkaConnectionError: 111 ECONNREFUSED
[kafka.conn] <BrokerConnection node_id=bootstrap host=127.0.0.1:9092 [IPv4 ('127.0.0.1', 9092)]>: reconnect backoff 0.05721221285863193 after 1 failures
[kafka.client] Unable to bootstrap from [('127.0.0.1', 9092, <AddressFamily.AF_INET: 2>)]
NoBrokersAvailable
[kafka.producer.kafka] Kafka producer closed
Here is the same code stuck on localhost:9092, not catching anything or even trying to reconnect:
[kafka.producer.kafka] Starting the Kafka producer
[kafka.client] Bootstrapping cluster metadata from [('localhost', 9092, <AddressFamily.AF_UNSPEC: 0>)]
[kafka.client] Attempting to bootstrap via node at localhost:9092
[kafka.conn] <BrokerConnection node_id=bootstrap host=localhost:9092 [unspecified None]>: creating new socket
[kafka.conn] <BrokerConnection node_id=bootstrap host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: setting socket option (6, 1, 1)
[kafka.conn] <BrokerConnection node_id=bootstrap host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: connecting to localhost:9092 [('127.0.0.1', 9092) IPv4]
[kafka.conn] Connect attempt to <BrokerConnection node_id=bootstrap host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]> returned error 111. Disconnecting.
[kafka.conn] <BrokerConnection node_id=bootstrap host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: Closing connection. KafkaConnectionError: 111 ECONNREFUSED
nothing else happens after that, it waits and don't try to reconnect.
it likes 127.0.0.1:9092 but can not handle localhost:9092, is there a reason?