From 0be3c1ef99f1f1a022a91f02af81a3a240db87f8 Mon Sep 17 00:00:00 2001
From: Matt Exact <70145864+MattExact@users.noreply.github.com>
Date: Tue, 7 May 2024 14:20:24 +0100
Subject: [PATCH] check all changes in replication message

---
 meilisync/source/postgres.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/meilisync/source/postgres.py b/meilisync/source/postgres.py
index 8651cbc..34900f6 100644
--- a/meilisync/source/postgres.py
+++ b/meilisync/source/postgres.py
@@ -95,7 +95,7 @@ def _consumer(self, msg: ReplicationMessage):
             kind = change.get("kind")
             table = change.get("table")
             if table not in self.tables:
-                return
+                continue
             columnnames = change.get("columnnames", [])
             columnvalues = change.get("columnvalues", [])
             columntypes = change.get("columntypes", [])