diff --git a/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/KafkaGroupMasterElector.java b/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/KafkaGroupMasterElector.java index 9baf021aed6c..fe2388797787 100644 --- a/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/KafkaGroupMasterElector.java +++ b/core/src/main/java/io/confluent/kafka/schemaregistry/masterelector/kafka/KafkaGroupMasterElector.java @@ -24,6 +24,7 @@ import org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient; import org.apache.kafka.common.Cluster; import org.apache.kafka.common.KafkaException; +import org.apache.kafka.common.config.ClientDnsLookup; import org.apache.kafka.common.metrics.JmxReporter; import org.apache.kafka.common.metrics.MetricConfig; import org.apache.kafka.common.metrics.Metrics; @@ -135,6 +136,7 @@ public KafkaGroupMasterElector(SchemaRegistryConfig config, clientConfig.getInt(CommonClientConfigs.SEND_BUFFER_CONFIG), clientConfig.getInt(CommonClientConfigs.RECEIVE_BUFFER_CONFIG), clientConfig.getInt(CommonClientConfigs.REQUEST_TIMEOUT_MS_CONFIG), + ClientDnsLookup.DEFAULT, time, true, new ApiVersions(),