localhost container is taken as the host because an instance of
is already running.
'''
self.producer = kaf(
key_serializer=str.encode,
localhost container is taken as the host because an instance of
is already running.
'''
self.producer = kaf(
key_serializer=str.encode,
bootstrap_servers=broker, api_version=(0, 10))
def publish(self, key, value, topic=None):
bootstrap_servers=broker, api_version=(0, 10))
def publish(self, key, value, topic=None):