diff --git a/physical/cassandra/cassandra.go b/physical/cassandra/cassandra.go index a7f22c468dc7..9e650f5ff830 100644 --- a/physical/cassandra/cassandra.go +++ b/physical/cassandra/cassandra.go @@ -150,6 +150,14 @@ func NewCassandraBackend(conf map[string]string, logger log.Logger) (physical.Ba cluster.Timeout = time.Duration(connectionTimeout) * time.Second } + if disableInitialHostLookupStr, ok := conf["disable_host_initial_lookup"]; ok { + disableInitialHostLookup, err := strconv.ParseBool(disableInitialHostLookupStr) + if err != nil { + return nil, fmt.Errorf("'disable_host_initial_lookup' must be a bool") + } + cluster.DisableInitialHostLookup = disableInitialHostLookup + } + if err := setupCassandraTLS(conf, cluster); err != nil { return nil, err }