Merge pull request #8672 from gyuho/require-leader

etcdctl/ctlv3: enable 'require-leader' for 'watch' command
etcd-io · Oct 9, 2017 · e47be1f · e47be1f
2 parents ed92420 + d44f7d5
commit e47be1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/etcdctl/ctlv3/command/watch_command.go b/etcdctl/ctlv3/command/watch_command.go
@@ -125,7 +125,7 @@ func getWatchChan(c *clientv3.Client, args []string) (clientv3.WatchChan, error)
 	if watchPrevKey {
 		opts = append(opts, clientv3.WithPrevKV())
 	}
-	return c.Watch(context.TODO(), key, opts...), nil
+	return c.Watch(clientv3.WithRequireLeader(context.Background()), key, opts...), nil
 }
 
 func printWatchCh(ch clientv3.WatchChan) {