(20250103) Added client object access to synchronous Kafka.
This commit is contained in:
@@ -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):
|
||||
|
||||
"""
|
||||
|
||||
Reference in New Issue
Block a user