From 6c4f55d17e2d9192856d46110aa9eec98e675d27 Mon Sep 17 00:00:00 2001
From: khushal <pskhushal@gmail.com>
Date: Fri, 3 Jan 2025 06:28:57 +0000
Subject: [PATCH] (20250103) Added client object access to synchronous Kafka.

---
 utils_v2/queue/kafka/controllers/kafka.py | 8 ++++++++
 1 file changed, 8 insertions(+)

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):
 
         """