diff --git a/pkg/config/etcd_source.go b/pkg/config/etcd_source.go index 05769dd01a..79136b91bf 100644 --- a/pkg/config/etcd_source.go +++ b/pkg/config/etcd_source.go @@ -133,7 +133,7 @@ func (es *EtcdSource) refreshConfigurations() error { ctx, cancel := context.WithTimeout(es.ctx, ReadConfigTimeout) defer cancel() - response, err := es.etcdCli.Get(ctx, prefix, clientv3.WithPrefix()) + response, err := es.etcdCli.Get(ctx, prefix, clientv3.WithPrefix(), clientv3.WithSerializable()) if err != nil { return err }