diff --git a/utils_v2/queue/kafka/controllers/kafka.py b/utils_v2/queue/kafka/controllers/kafka.py
index b1aa283..96fb130 100644
--- a/utils_v2/queue/kafka/controllers/kafka.py
+++ b/utils_v2/queue/kafka/controllers/kafka.py
@@ -171,6 +171,10 @@ class ProducerKafka:
         # Done here:
         return config
 
+    @property
+    def client(self) -> Producer:
+        return self.__producer
+
     def connect(self) -> bool:
 
         """
@@ -358,6 +362,10 @@ class ConsumerKafka:
         # Done here:
         return config
 
+    @property
+    def client(self) -> Consumer:
+        return self.__consumer
+
     def connect(self):
 
         """