diff --git a/stopover/broker.py b/stopover/broker.py
index 6d38dd1..23cf26b 100755
--- a/stopover/broker.py
+++ b/stopover/broker.py
@@ -255,9 +255,9 @@ def _get_stream_partition_numbers(self, stream: str):
             partition_numbers = []
             self.partitions_by_stream[stream] = partition_numbers
 
-            if 'streams' in self.config and stream in self.config['streams']:
+            try:
                 partitions_target = self.config['streams'][stream]['partitions']
-            else:
+            except KeyError:
                 partitions_target = self.config['global']['partitions']
 
             stream_path = self._get_stream_path(stream)
diff --git a/stopover/partition.py b/stopover/partition.py
index 28807c6..41767be 100755
--- a/stopover/partition.py
+++ b/stopover/partition.py
@@ -129,7 +129,7 @@ def prune(self, ttl: int):
         keys_to_delete = []
 
         with self.lock:
-            for key, value in self._store.scan(prefix='message:'):
+            for key, value in self._store.scan(prefix=Partition.MESSAGE):
 
                 # Backwards compatibility
                 if isinstance(value, bytes):
diff --git a/stopover/stopover.py b/stopover/stopover.py
index 74e1ed0..bbcda82 100755
--- a/stopover/stopover.py
+++ b/stopover/stopover.py
@@ -1,7 +1,7 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 
-version = '2.214.0'
+version = '2.214.1'
 
 banner = f"""
   ███████████                             ███████████