diff --git a/srnemqtt/config.py b/srnemqtt/config.py
index ccff24d..de435eb 100644
--- a/srnemqtt/config.py
+++ b/srnemqtt/config.py
@@ -12,7 +12,7 @@ from .consumers import BaseConsumer
 def get_consumer(name: str) -> Optional[Type[BaseConsumer]]:
     mod_name, cls_name = name.rsplit(".", 1)
 
-    mod = importlib.import_module(f"consumers.{mod_name}")
+    mod = importlib.import_module(f".consumers.{mod_name}", package=__package__)
 
     # print(mod)
     # print(dir(mod))