diff --git a/goblin/driver/cluster.py b/goblin/driver/cluster.py
index 6759340632ccd0d0f7d7a4c952ef63a5677cca2b..74354df28ec96db435f33781b56bf6eac591db6d 100644
--- a/goblin/driver/cluster.py
+++ b/goblin/driver/cluster.py
@@ -183,7 +183,7 @@ class Cluster:
         for item in dir(module):
             if not item.startswith('_') and item.lower() in self.DEFAULT_CONFIG:
                 config[item.lower()] = getattr(module, item)
-        config = self._get_message_serializer(config)
+        config = self._process_config_imports(config)
         self.config.update(config)
 
     async def connect(self, processor=None, op=None, aliases=None,