diff --git a/tap_clari/streams.py b/tap_clari/streams.py
index 9f6155c..e8f5ba9 100644
--- a/tap_clari/streams.py
+++ b/tap_clari/streams.py
@@ -20,7 +20,12 @@ def __init__(self, tap, forecast_id: str):
         )
         self.forecast_id = forecast_id
 
-    primary_keys: t.ClassVar[list[str]] = ["entries"]
+    primary_keys: t.ClassVar[list[str]] = [
+        "fieldId",
+        "timeFrameId",
+        "timePeriodId",
+        "userId"
+    ]
     replication_key = None
     schema = th.PropertiesList(
         th.Property("adjustmentValue", th.NumberType),