diff --git a/example/pglogrepl_demo/main.go b/example/pglogrepl_demo/main.go
index 9118c66..cc87d2e 100644
--- a/example/pglogrepl_demo/main.go
+++ b/example/pglogrepl_demo/main.go
@@ -88,7 +88,7 @@ func main() {
 		}
 
 		if errMsg, ok := rawMsg.(*pgproto3.ErrorResponse); ok {
-			return fmt.Errorf("received Postgres WAL error: %+v", errMsg)
+			log.Fatalf("received Postgres WAL error: %+v", errMsg)
 		}
 
 		msg, ok := rawMsg.(*pgproto3.CopyData)