diff --git a/go/vt/topo/etcd2topo/watch.go b/go/vt/topo/etcd2topo/watch.go index a3edf727b55..6bda2f85423 100644 --- a/go/vt/topo/etcd2topo/watch.go +++ b/go/vt/topo/etcd2topo/watch.go @@ -259,7 +259,7 @@ func (s *Server) WatchRecursive(ctx context.Context, dirpath string) ([]*topo.Wa Path: string(ev.Kv.Key), WatchData: topo.WatchData{ Contents: ev.Kv.Value, - Version: EtcdVersion(ev.Kv.Version), + Version: EtcdVersion(ev.Kv.ModRevision), }, } case mvccpb.DELETE: