diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py
index 9507afc62..1c0d64074 100644
--- a/faust/stores/rocksdb.py
+++ b/faust/stores/rocksdb.py
@@ -289,7 +289,12 @@ def _open_for_partition(self, partition: int) -> DB:
 
     def _get(self, key: bytes) -> Optional[bytes]:
         event = current_event()
-        if event is not None:
+        partition_from_message = (
+            event is not None
+            and not self.table.is_global
+            and not self.table.use_partitioner
+        )
+        if partition_from_message:
             partition = event.message.partition
             db = self._db_for_partition(partition)
             value = db.get(key)