diff --git a/zk/datastream/client/stream_client.go b/zk/datastream/client/stream_client.go
index 43f24eb599a..17f849c8fc1 100644
--- a/zk/datastream/client/stream_client.go
+++ b/zk/datastream/client/stream_client.go
@@ -317,7 +317,7 @@ LOOP:
 		case *types.BatchStart:
 			c.currentFork = parsedProto.ForkId
 			c.entryChan <- parsedProto
-		case *types.GerUpdateProto:
+		case *types.GerUpdate:
 			c.entryChan <- parsedProto
 		case *types.BatchEnd:
 			c.entryChan <- parsedProto