Exception not raised by the KafkaConsumer() method for invalid address

[aliartiza75]

Hello everyone,

In the earlier version of the Kafka-python module, the method KafkaConsumer() when received an invalid broker address used to raise an exception but in the latest version, it neither raises an exception nor timeouts but stucks at that point.
Module version is : 1.4.2

client = KafkaConsumer(bootstrap_servers=broker_addr, request_timeout_ms=6000, session_timeout_ms=5000)

Need help regarding the behavior of this method.

Thanks in advance

[affansyed]

+1. This is breaking lots of unittests at our place.

[jeffwidman]

When you say invalid, what kind of invalid?

Is it a validly formed host that simply doesn't have a running broker or a completely malformed hostname that will never work?

Related: #1473

[aliartiza75]

Malformed addresses example are given below:

• "invalid_addresss"
• "444.444.22.11"

and yes it relates to #1473

[dpkp]

Fixed via #1507