diff --git a/cmd/streams/play.go b/cmd/streams/play.go
index 5456676c..6cf63ad7 100644
--- a/cmd/streams/play.go
+++ b/cmd/streams/play.go
@@ -26,8 +26,8 @@ func (s *Stream) Play(source string) error {
 		}
 
 		// check if client support consumer interface
-		cons := client.(streamer.Consumer)
-		if cons == nil {
+		cons, ok := client.(streamer.Consumer)
+		if !ok {
 			continue
 		}