diff --git a/go/internal/pusher/conn.go b/go/internal/pusher/conn.go
index bcaa3f9..4a81645 100644
--- a/go/internal/pusher/conn.go
+++ b/go/internal/pusher/conn.go
@@ -44,6 +44,11 @@ func (c *Conn) ReadPump(ctx context.Context, hub *Hub) {
 			return
 		}
 
+		// Ignore keep-alive pings
+		if string(data) == "ping" {
+			continue
+		}
+
 		var msg ClientMessage
 		if err := json.Unmarshal(data, &msg); err != nil {
 			c.sendError("invalid message format")