client: add extra appender read of EOF

work-around for grpc-ecosystem/go-grpc-prometheus#92
jgraettinger · May 31, 2020 · 5ccd0ce · 5ccd0ce
1 parent 8f0e3ca
commit 5ccd0ce
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/broker/client/appender.go b/broker/client/appender.go
@@ -102,6 +102,10 @@ func (a *Appender) Close() (err error) {
 		default:
 			err = errors.New(a.Response.Status.String())
 		}
+
+		// Extra RecvMsg to explicitly read EOF, as a work-around for
+		// https://github.com/grpc-ecosystem/go-grpc-prometheus/issues/92
+		_ = a.stream.RecvMsg(new(pb.AppendResponse))
 	}
 
 	if err != nil {