[KAFKA-2657] Kafka clients fail to start if one of broker isn't resolved by DNS - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Minor
Resolution: Duplicate
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

During org.apache.kafka.clients.producer.KafkaProducer and org.apache.kafka.clients.consumer.KafkaConsumer object creation constructors invoke org.apache.kafka.common.utils.ClientUtils#parseAndValidateAddresses
which potentially could throw an exception if one the nodes hasn't been resolved by DNS. As a result of that - object hasn't been created and you aren't able to use Kafka clients.

I personally think that Kafka should be able to operate with cluster with quorum number of instances.

try {
    InetSocketAddress address = new InetSocketAddress(host, port);
    if (address.isUnresolved())
        throw new ConfigException("DNS resolution failed for url in " + ProducerConfig.BOOTSTRAP_SERVERS_CONFIG + ": " + url);
    addresses.add(address);
} catch (NumberFormatException e) {
    throw new ConfigException("Invalid port in " + ProducerConfig.BOOTSTRAP_SERVERS_CONFIG + ": " + url);
}