diff --git a/etcdserver/api/rafthttp/http.go b/etcdserver/api/rafthttp/http.go
index 98afdc698..51dd290cc 100644
--- a/etcdserver/api/rafthttp/http.go
+++ b/etcdserver/api/rafthttp/http.go
@@ -445,7 +445,7 @@ func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		Flusher: w.(http.Flusher),
 		Closer:  c,
 		localID: h.tr.ID,
-		peerID:  h.id,
+		peerID:  from,
 	}
 	p.attachOutgoingConn(conn)
 	<-c.closeNotify()